次の方法で共有

PublishedPipeline クラス

パイプラインを構築した Python コードなしで送信されるパイプラインを表します。

さらに、PublishedPipeline を使用して、異なるPipeline値と入力を持つPipelineParameterを再送信できます。

PublishedPipeline を初期化します。

:p aram エンドポイント: このパイプラインのパイプライン実行を送信する REST エンドポイント URL。 :type endpoint: str :p aram total_run_steps: このパイプラインのステップの数:type total_run_steps: int :p aram workspace: 発行されたパイプラインのワークスペース。 :type workspace: azureml.core.Workspace :p aram continue_on_step_failure: PipelineRun で他のステップの実行を続行するかどうか

ステップが失敗した場合、既定値は false です。

コンストラクター

PublishedPipeline(name, graph_id, description, version, published_pipeline_id, status, endpoint, total_run_steps, workspace, continue_on_step_failure=None, _pipeline_provider=None, **kwargs)

パラメーター

名前 説明
name
必須
str

発行されたパイプラインの名前。
graph_id
必須
str

この発行されたパイプラインのグラフの ID。
description
必須
str

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

発行されたパイプラインのバージョン。
published_pipeline_id
必須
str

発行されたパイプラインの ID。
status
必須
str

発行されたパイプラインの状態 ('Active' または 'Disabled')。
endpoint
必須
str

このパイプラインの実行を送信する REST エンドポイント URL。
total_run_steps
必須
int

このパイプライン内のステップの数。
workspace
必須
Workspace

発行されたパイプラインのワークスペース。
continue_on_step_failure
必須
bool

ステップが失敗した場合に PipelineRun の他のステップの実行を続行するかどうか。 既定値は false です。
_pipeline_provider
必須
<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>

発行されたパイプライン プロバイダー。
kwargs
必須
dict

カスタム キーワード引数(将来の開発用に予約済み)
name
必須
str

発行されたパイプラインの名前。
graph_id
必須
str

この発行されたパイプラインのグラフの ID。
description
必須
str

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

発行されたパイプラインのバージョン。
published_pipeline_id
必須
str

発行されたパイプラインの ID。
status
必須
str

発行されたパイプラインの状態 ('Active' または 'Disabled')。
_pipeline_provider
必須
<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>

発行されたパイプライン プロバイダー。
kwargs
必須
dict

カスタム キーワード引数(将来の開発用に予約済み)

注釈

PublishedPipeline は、 Pipeline または PipelineRunから作成できます。

パイプラインから発行する例を次に示します。


   from azureml.pipeline.core import Pipeline

   pipeline = Pipeline(workspace=ws, steps=steps)
   published_pipeline = pipeline.publish(name="My_New_Pipeline",
                                         description="My New Pipeline Description",
                                         version="1.0",
                                         continue_on_step_failure=True)

PipelineRun から発行するには、次のコマンドを使用します。


   from azureml.pipeline.core import PipelineRun

   pipeline_run = PipelineRun(experiment=Experiment(ws, "Pipeline_experiment"), run_id="run_id")
   published_pipeline = pipeline_run.publish_pipeline(name="My_New_Pipeline",
                                                      description="My New Pipeline Description",
                                                      version="1.0",
                                                      continue_on_step_failure=True)

注: continue_on_step_failure パラメーターは、1 つのステップが失敗した場合にパイプラインでのステップの実行を続行するかどうかを指定します。 既定値は False です。つまり、1 つのステップが失敗すると、パイプラインの実行が停止し、実行中のステップが取り消されます。

submitを使用して PublishedPipeline を送信します。 送信が呼び出されると、 PipelineRun が作成され、ワークフロー内の各ステップ StepRun オブジェクトが作成されます。

PublishedPipeline を送信する例を次に示します。


   from azureml.pipeline.core import PublishedPipeline

   published_pipeline = PublishedPipeline.get(workspace=ws, id="published_pipeline_id")
   pipeline_run = experiment.submit(published_pipeline)

PublishedPipeline を送信するときに指定できるオプションの設定がいくつかあります。 これには以下が含まれます:

  • continue_on_step_failure: ステップが失敗した場合に PipelineRun の他のステップの実行を続行するかどうか(省略可能)。 失敗したステップの出力に依存しないステップのみが実行を続行します。 指定した場合、このパラメーター設定はパイプラインの設定をオーバーライドします。

  • pipeline_parameters: パイプライン実行のパラメーター、{name: value} のディクショナリ。 詳細については、PipelineParameter を参照してください。

  • parent_run_id: 実行 ID を指定して、このパイプライン実行の親実行を設定できます。これは RunHistory に反映されます。 親の実行は、送信されるパイプラインと同じ実験に属している必要があります。

これらの設定を使用して PublishedPipeline を送信する例を次に示します。


   from azureml.pipeline.core import PublishedPipeline

   published_pipeline = PublishedPipeline.get(workspace=ws, id="published_pipeline_id")
   pipeline_run = experiment.submit(published_pipeline,
                                    continue_on_step_failure=True,
                                    pipeline_parameters={"param1": "value1"},
                                    parent_run_id="<run_id>")

発行されたすべてのパイプラインに REST エンドポイントがあります。 パイプライン エンドポイントを使用すると、Python 以外のクライアントなどの外部システムからパイプラインの実行をトリガーできます。 REST エンドポイントを呼び出すときに認証する方法については、 https://aka.ms/pl-restep-authを参照してください。

エンドポイントを使用すると、たとえば、バッチ スコアリングと再トレーニングのシナリオで "マネージド反復性" が有効になります。 詳細については、https://aka.ms/pl-first-pipelineを参照してください。

メソッド

disable

発行されたパイプラインを "無効" に設定し、実行できません。
enable

発行されたパイプラインを "アクティブ" に設定し、実行できるようにします。
get

発行されたパイプラインを取得します。
get_all

現在のワークスペース内のすべての発行済みパイプラインを取得します。

非推奨: このメソッドは、PublishedPipeline list メソッドを優先して非推奨とされています。
get_graph

PublishedPipeline のグラフを取得します。
get_step_names

PublishedPipeline のステップの名前の一覧を取得します。
list

現在のワークスペース内のすべての発行済みパイプラインを取得します。
save

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

現在、YAML エクスポートでは ModuleSteps で構成されるパイプラインのみがサポートされています。
submit

発行されたパイプラインを送信します。 これは、 submitの使用と同じです。

送信された PipelineRunを返します。 このオブジェクトを使用して、実行の詳細を監視および表示します。

disable

発行されたパイプラインを "無効" に設定し、実行できません。

disable()

enable

発行されたパイプラインを "アクティブ" に設定し、実行できるようにします。

enable()

get

発行されたパイプラインを取得します。

static get(workspace, id, _workflow_provider=None, _service_endpoint=None)

パラメーター

名前 説明
workspace
必須
Workspace

発行されたパイプラインが作成されたワークスペース。
id
必須
str

発行されたパイプラインの ID。
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

ワークフロー プロバイダー。

規定値: None
_service_endpoint
str

サービス エンドポイント。

規定値: None

戻り値

型 説明
PublishedPipeline

PublishedPipeline オブジェクト。

get_all

現在のワークスペース内のすべての発行済みパイプラインを取得します。

非推奨: このメソッドは、PublishedPipeline list メソッドを優先して非推奨とされています。

static get_all(workspace, active_only=True, _service_endpoint=None)

パラメーター

名前 説明
workspace
必須
Workspace

発行されたパイプラインが作成されたワークスペース。
active_only
bool

現在アクティブな発行済みパイプラインのみを返すかどうか。

規定値: True
_service_endpoint
str

サービス エンドポイント。

規定値: None

戻り値

型 説明
list[PublishedPipeline]

PublishedPipeline オブジェクトの一覧。

get_graph

PublishedPipeline のグラフを取得します。

get_graph(_workflow_provider=None)

パラメーター

名前 説明
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

ワークフロー プロバイダー。

規定値: None

戻り値

型 説明
Graph

グラフ。

get_step_names

PublishedPipeline のステップの名前の一覧を取得します。

get_step_names(_workflow_provider=None)

パラメーター

名前 説明
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

ワークフロー プロバイダー。

規定値: None

戻り値

型 説明
List[str]

PublishedPipeline 内のステップの名前の一覧。

list

現在のワークスペース内のすべての発行済みパイプラインを取得します。

static list(workspace, active_only=True, _service_endpoint=None)

パラメーター

名前 説明
workspace
必須
Workspace

発行されたパイプラインが作成されたワークスペース。
active_only
bool

現在アクティブな発行済みパイプラインのみを返すかどうか。

規定値: True
_service_endpoint
str

サービス エンドポイント。

規定値: None

戻り値

型 説明
list[PublishedPipeline]

PublishedPipeline オブジェクトの一覧。

save

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

現在、YAML エクスポートでは ModuleSteps で構成されるパイプラインのみがサポートされています。

save(path=None, _workflow_provider=None)

パラメーター

名前 説明
path
str

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

規定値: None
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

ワークフロー プロバイダー。

規定値: None

戻り値

型 説明
None

submit

発行されたパイプラインを送信します。 これは、 submitの使用と同じです。

送信された PipelineRunを返します。 このオブジェクトを使用して、実行の詳細を監視および表示します。

submit(workspace, experiment_name, pipeline_parameters=None, _workflow_provider=None, _service_endpoint=None, parent_run_id=None, continue_on_step_failure=None)

パラメーター

名前 説明
workspace
必須
Workspace

発行されたパイプラインを送信するワークスペース。
experiment_name
必須
str

送信する実験の名前。
pipeline_parameters
dict

新しい値 {param name, param value} を割り当てるパラメーターのディクショナリ。 詳細については、PipelineParameter を参照してください。

規定値: None
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

ワークフロー プロバイダー。

規定値: None
_service_endpoint
str

サービス エンドポイント。

規定値: None
parent_run_id
str

RunHistory に反映される、このパイプライン実行の親実行に設定するオプションの実行 ID。 親の実行は、このパイプラインが送信されるのと同じ実験に属している必要があります。

規定値: None
continue_on_step_failure
bool

ステップが失敗した場合に PipelineRun の他のステップの実行を続行するかどうか(省略可能)。 指定した場合は、パイプラインの設定をオーバーライドします。

規定値: None

戻り値

型 説明
PipelineRun

送信されたパイプラインの実行。

属性

continue_on_step_failure

continue_on_step_failure設定の値を取得します。

戻り値

型 説明
bool

continue_on_step_failure設定の値。

description

発行されたパイプラインの説明を取得します。

戻り値

型 説明
str

発行されたパイプラインの説明。

endpoint

発行されたパイプラインを実行するための REST エンドポイント URL を取得します。

戻り値

型 説明
str

発行されたパイプラインを実行するための REST エンドポイント URL。

graph_id

この発行されたパイプラインのグラフの ID を取得します。

戻り値

型 説明
str

グラフの ID。

id

発行されたパイプライン ID を取得します。

戻り値

型 説明
str

発行されたパイプラインの ID。

name

発行されたパイプラインの名前を取得します。

戻り値

型 説明
str

発行されたパイプライン名。

status

発行されたパイプラインの状態を取得します。

戻り値

型 説明
str

発行されたパイプラインの状態。

total_run_steps

パイプライン内のステップの数を取得します。

戻り値

型 説明
int

パイプライン内のステップの数。

version

発行されたパイプラインのバージョンを取得します。

戻り値

型 説明
str

発行されたパイプラインのバージョン。