次の方法で共有

PipelineRun クラス

  • リファレンス

Pipelineの実行を表します。

このクラスは、パイプライン実行が送信された後の管理、状態の検査、実行の詳細の取得に使用できます。 get_stepsを使用して、パイプライン実行によって作成されるStepRunオブジェクトを取得します。 その他の用途には、パイプライン実行に関連付けられているGraphオブジェクトの取得、パイプライン実行の状態のフェッチ、実行完了の待機などがあります。

パイプラインの実行を初期化します。

継承
Run
PipelineRun

コンストラクター

PipelineRun(experiment, run_id, _service_endpoint=None, **kwags)

パラメーター

名前 説明
experiment
必須
Experiment

パイプライン実行に関連付けられている実験オブジェクト。
run_id
必須
str

パイプライン実行の実行 ID。
_service_endpoint
str

接続先エンドポイント。

規定値: None
experiment
必須
Experiment

パイプライン実行に関連付けられている実験オブジェクト。
run_id
必須
str

パイプライン実行の実行 ID。
_service_endpoint
必須
str

接続先エンドポイント。

注釈

submitメソッド を介してPipelineを送信するとき (Experimentの submit メソッドを使用)、PipelineRun オブジェクトが返されます。 パイプラインを作成して送信する方法の詳細については、https://aka.ms/pl-first-pipelineを参照してください。

PipelineRun は、次のように、実行の送信先のExperimentと PipelineRun ID を使用してインスタンス化することもできます。


   from azureml.core import Experiment
   from azureml.pipeline.core import PipelineRun

   experiment = Experiment(workspace, "<experiment_name>")
   pipeline_run = PipelineRun(experiment, "<pipeline_run_id>")

PipelineRun を操作する場合は、次を使用します。

  • wait_for_completion: 実行状態を監視し、必要に応じて実行ログをストリーミングします。

  • get_status を使用して、実行状態をフェッチします。

  • cancel を使用して、進行中の PipelineRun を取り消します。

  • get_steps: 生成された StepRuns のリストを表示します。 PipelineRun は、パイプライン内のステップごとにStepRunを生成します。

メソッド

cancel

進行中の実行をキャンセルします。
child_run

パイプライン実行の子の実行を作成します。 このメソッドは PipelineRun に対して実装されていません。
complete

パイプライン実行を完了としてマークします。 このメソッドは PipelineRun に対して実装されていません。

このメソッドは、パイプラインではサポートされていません。completion/failed 状態は、Azure ML バックエンドによって管理されます。
fail

パイプライン実行を失敗としてマークします。 このメソッドは PipelineRun に対して実装されていません。

このメソッドは、パイプラインではサポートされていません。completion/failed 状態は、Azure ML バックエンドによって管理されます。
find_step_run

パイプライン内のステップ実行を名前で検索します。
get

実行 ID に基づいてパイプライン実行をフェッチします。
get_graph

パイプライン実行のグラフを取得します。
get_pipeline_output

指定されたパイプライン出力の PortDataReference を取得します。
get_pipeline_runs

発行済みパイプラインから生成されたパイプラインの実行をフェッチします。
get_status

サービスからパイプライン実行の最新の状態をフェッチします。

一般的には "Running"、"Finished"、"Failed" などの値が返されます。
get_steps

完了したか実行を開始したすべてのパイプライン ステップのステップ実行を取得します。
get_tags

実行のタグのセットを取得します。
publish_pipeline

パイプラインを発行し、再実行できるようにします。

この関数によって返される PublishedPipeline オブジェクトからパイプライン エンドポイントを取得できます。 パイプライン エンドポイントを使用すると、REST 呼び出しを使用して外部アプリケーションからパイプラインを起動できます。 REST エンドポイントを呼び出すときの認証方法については、https://aka.ms/pl-restep-authを参照してください。

パイプライン実行に関連付けられている元のパイプラインは、発行済みパイプラインのベースとして使用されます。
save

パイプライン YAML をファイルに保存します。
wait_for_completion

このパイプライン実行が完了するまで待機します。

待機後の状態を返します。

cancel

進行中の実行をキャンセルします。

cancel()

child_run

パイプライン実行の子の実行を作成します。 このメソッドは PipelineRun に対して実装されていません。

child_run(name=None, run_id=None, outputs=None)

パラメーター

名前 説明
name
str

子の省略可能な名前。

規定値: None
run_id
str

子の省略可能な実行 ID。指定されていない場合は既定値が使用されます。

規定値: None
outputs
str

子の省略可能な追跡用出力ディレクトリ。

規定値: None

戻り値

型 説明
Run

子の実行。

例外

型 説明
NotImplementedError

complete

パイプライン実行を完了としてマークします。 このメソッドは PipelineRun に対して実装されていません。

このメソッドは、パイプラインではサポートされていません。completion/failed 状態は、Azure ML バックエンドによって管理されます。

complete()

例外

型 説明
NotImplementedError

fail

パイプライン実行を失敗としてマークします。 このメソッドは PipelineRun に対して実装されていません。

このメソッドは、パイプラインではサポートされていません。completion/failed 状態は、Azure ML バックエンドによって管理されます。

fail()

例外

型 説明
NotImplementedError

find_step_run

パイプライン内のステップ実行を名前で検索します。

find_step_run(name)

パラメーター

名前 説明
name
必須
str

検索するステップの名前。

戻り値

型 説明
list

指定された名前のStepRunオブジェクトのリスト。

get

実行 ID に基づいてパイプライン実行をフェッチします。

static get(workspace, run_id, _service_endpoint=None)

パラメーター

名前 説明
workspace
必須
Workspace

パイプラインに関連付けられているワークスペース。
run_id
必須
str

パイプラインの実行の ID。
_service_endpoint
str

接続先エンドポイント。

規定値: None

戻り値

型 説明
PipelineRun

PipelineRun オブジェクト。

get_graph

パイプライン実行のグラフを取得します。

get_graph()

戻り値

型 説明
Graph

グラフ。

get_pipeline_output

指定されたパイプライン出力の PortDataReference を取得します。

get_pipeline_output(pipeline_output_name)

パラメーター

名前 説明
pipeline_output_name
必須
str

取得するパイプライン出力の名前。

戻り値

型 説明
PortDataReference

パイプライン出力データを表す PortDataReference。

get_pipeline_runs

発行済みパイプラインから生成されたパイプラインの実行をフェッチします。

static get_pipeline_runs(workspace, pipeline_id, _service_endpoint=None)

パラメーター

名前 説明
workspace
必須
Workspace

パイプラインに関連付けられているワークスペース。
pipeline_id
必須
str

発行済みパイプラインの ID。
_service_endpoint
str

接続先エンドポイント。

規定値: None

戻り値

型 説明
list

PipelineRun オブジェクトのリスト。

get_status

サービスからパイプライン実行の最新の状態をフェッチします。

一般的には "Running"、"Finished"、"Failed" などの値が返されます。

get_status()

戻り値

型 説明
str

文字列としての最新の状態。

注釈

  • NotStarted - これは、クラウド送信前のクライアント側 Run オブジェクトの一時的な状態です

  • Running - コンピューティング先でジョブの実行が開始されました。

  • Failed - 実行が失敗しました。 通常は実行の Error プロパティで、理由に関する詳細が提供されます。

  • Completed - 実行は正常に完了しました。

  • Canceled - 取り消し要求の後、実行は正常に取り消されました。


   run = experiment.submit(config)
   while run.get_status() not in ['Finished', 'Failed']: # For example purposes only, not exhaustive
       print('Run {} not in terminal state'.format(run.id))
       time.sleep(10)

get_steps

完了したか実行を開始したすべてのパイプライン ステップのステップ実行を取得します。

get_steps()

戻り値

型 説明
list

StepRun オブジェクトのリスト。

get_tags

実行のタグのセットを取得します。

get_tags()

戻り値

型 説明
dict

実行のタグの辞書。

publish_pipeline

パイプラインを発行し、再実行できるようにします。

この関数によって返される PublishedPipeline オブジェクトからパイプライン エンドポイントを取得できます。 パイプライン エンドポイントを使用すると、REST 呼び出しを使用して外部アプリケーションからパイプラインを起動できます。 REST エンドポイントを呼び出すときの認証方法については、https://aka.ms/pl-restep-authを参照してください。

パイプライン実行に関連付けられている元のパイプラインは、発行済みパイプラインのベースとして使用されます。

publish_pipeline(name, description, version, continue_on_step_failure=None, **kwargs)

パラメーター

名前 説明
name
必須
str

発行済みパイプラインの名前。
description
必須
str

発行されたパイプラインの説明。
version
必須
str

発行済みパイプラインのバージョン。
continue_on_step_failure
bool

あるステップが失敗した場合に、PipelineRun 内の別のステップの実行を続行するかどうか。 既定値は False です。

規定値: None
kwargs
必須
dict

カスタム キーワード引数。将来の開発用に予約されています

戻り値

型 説明
PublishedPipeline

作成された発行済みパイプライン。

save

パイプライン YAML をファイルに保存します。

save(path=None)

パラメーター

名前 説明
path
str

YAML の保存先パス。 パスがディレクトリの場合、パイプライン YAML ファイルは<path>/pipeline.yml に保存されます。 パスが None の場合は、現在のディレクトリが使用されます。

規定値: None

戻り値

型 説明
None

wait_for_completion

このパイプライン実行が完了するまで待機します。

待機後の状態を返します。

wait_for_completion(show_output=True, timeout_seconds=9223372036854775807, raise_on_error=True)

パラメーター

名前 説明
show_output
bool

sys.stdout 上でパイプライン実行の状態を表示するかどうかを示します。

規定値: True
timeout_seconds
int

タイムアウトになるまで待機する秒数。

規定値: 9223372036854775807
raise_on_error
bool

実行が失敗状態のときにエラーを発生させるかどうかを示します。

規定値: True

戻り値

型 説明
str

最終的な状態。