PipelineDraft Classe
Representa um pipeline mutável que pode ser usado para enviar execuções e criar Pipelines Publicados.
Use PipelineDrafts para iterar em Pipelines. PipelineDrafts podem ser criados do zero, de outro PipelineDraft ou de pipelines existentes: Pipeline, PublishedPipeline ou PipelineRun.
Inicializar PipelineDraft.
- Herança
-
builtins.objectPipelineDraft
Construtor
PipelineDraft(workspace, id, name=None, description=None, experiment_name=None, tags=None, properties=None, graph_draft_id=None, parent_pipeline_id=None, parent_pipeline_run_id=None, parent_step_run_ids=None, parent_pipeline_draft_id=None, last_submitted_pipeline_run_id=None, _pipeline_draft_provider=None)
Parâmetros
Nome | Description |
---|---|
workspace
Obrigatório
|
O objeto de workspace para esse PipelineDraft. |
id
Obrigatório
|
A ID do PipelineDraft. |
name
Obrigatório
|
O nome do PipelineDraft. |
description
Obrigatório
|
A descrição do PipelineDraft. |
experiment_name
Obrigatório
|
O nome do experimento para o PipelineDraft. |
tags
Obrigatório
|
Um dicionário de marcas opcional para o PipelineDraft. |
properties
Obrigatório
|
Um dicionário de propriedades opcional para o PipelineDraft. |
graph_draft_id
Obrigatório
|
O ID do rascunho do grafo associado ao PipelineDraft. |
parent_pipeline_id
Obrigatório
|
A ID do PublishedPipeline pai. |
parent_pipeline_run_id
Obrigatório
|
A ID do PipelineRun pai. |
parent_step_run_ids
Obrigatório
|
Uma lista das IDs de StepRun do PipelineRun pai. |
parent_pipeline_draft_id
Obrigatório
|
A ID do PipelineDraft pai. |
last_submitted_pipeline_run_id
Obrigatório
|
A ID do último PipelineRun enviado. |
_pipeline_draft_provider
Obrigatório
|
<xref:azureml.pipeline.core._aeva_provider._AevaPipelineDraftProvider>
(Somente uso interno.) O provedor PipelineDraft. |
workspace
Obrigatório
|
Objeto workspace para este PipelineDraft. |
id
Obrigatório
|
A ID do PipelineDraft. |
name
Obrigatório
|
O nome do PipelineDraft. |
description
Obrigatório
|
A descrição do PipelineDraft. |
experiment_name
Obrigatório
|
O nome do experimento para o PipelineDraft. |
tags
Obrigatório
|
Dicionário de marcas para o PipelineDraft. |
properties
Obrigatório
|
Dicionário de propriedades para o PipelineDraft. |
graph_draft_id
Obrigatório
|
A ID do rascunho do grafo associado ao PipelineDraft. |
parent_pipeline_id
Obrigatório
|
A ID do PublishedPipeline pai. |
parent_pipeline_run_id
Obrigatório
|
A ID do PipelineRun pai. |
parent_step_run_ids
Obrigatório
|
Uma lista das IDs StepRun do PipelineRun pai. |
parent_pipeline_draft_id
Obrigatório
|
A ID do PipelineDraft pai. |
last_submitted_pipeline_run_id
Obrigatório
|
A ID do último PipelineRun enviado. |
_pipeline_draft_provider
Obrigatório
|
<xref:azureml.pipeline.core._aeva_provider._AevaPipelineDraftProvider>
O provedor do PipelineDraft. |
Comentários
Um PipelineDraft pode ser criado a partir de um Pipeline usando a função create. Veja um exemplo abaixo:
from azureml.pipeline.core import Pipeline, PipelineDraft
from azureml.pipeline.steps import PythonScriptStep
train_step = PythonScriptStep(name="Training_Step",
script_name="train.py",
compute_target=aml_compute_target,
source_directory=".")
pipeline = Pipeline(workspace=ws, steps=[train_step])
pipeline_draft = PipelineDraft.create(workspace=ws,
name="TestPipelineDraft",
description="draft description",
experiment_name="helloworld",
pipeline=pipeline,
continue_on_step_failure=True,
tags={'dev': 'true'},
properties={'train': 'value'})
O parâmetro de pipeline do PipelineDraft.create() também pode ser um PublishedPipeline, PipelineRun ou outro PipelineDraft.
Para enviar uma execução de um PipelineDraft, use o método submit_run:
pipeline_run = pipeline_draft.submit_run()
Para atualizar um PipelineDraft, use o método update. A função update() de um rascunho de pipeline pode ser usada para atualizar o nome, a descrição, o nome do experimento, as atribuições de parâmetros do pipeline, continuar na configuração de falha da etapa e o pipeline associado ao PipelineDraft.
new_train_step = PythonScriptStep(name="New_Training_Step",
script_name="train.py",
compute_target=aml_compute_target,
source_directory=source_directory)
new_pipeline = Pipeline(workspace=ws, steps=[new_train_step])
pipeline_draft.update(name="UpdatedPipelineDraft",
description="has updated train step",
pipeline=new_pipeline)
Métodos
create |
Cria um PipelineDraft. |
delete |
Exclui o PipelineDraft. |
get |
Obtém o PipelineDraft com a ID fornecida. |
get_graph |
Obter o gráfico associado ao PipelineDraft. |
list |
Obtém todos os rascunhos de pipeline em um workspace. |
publish |
Publica um PublishedPipeline do PipelineDraft. |
save |
Salve o YAML do PipelineDraft em um arquivo. |
submit_run |
Envia um PipelineRun do PipelineDraft. |
update |
Atualiza um PipelineDraft. Os campos fornecidos serão atualizados. |
create
Cria um PipelineDraft.
static create(workspace, pipeline, name=None, description=None, experiment_name=None, pipeline_parameters=None, continue_on_step_failure=None, tags=None, properties=None, _workflow_provider=None, _service_endpoint=None)
Parâmetros
Nome | Description |
---|---|
workspace
Obrigatório
|
O objeto de workspace ao qual esse PipelineDraft pertencerá. |
pipeline
Obrigatório
|
O pipeline ou o pipeline publicado. |
name
|
O nome do PipelineDraft; necessário apenas ao criar a partir de um arquivo Pipeline. Valor padrão: None
|
description
|
A descrição do PipelineDraft; necessário apenas ao criar a partir de um arquivo Pipeline. Valor padrão: None
|
experiment_name
|
O nome do experimento para o PipelineDraft; necessário apenas ao criar a partir de um arquivo Pipeline. Valor padrão: None
|
pipeline_parameters
|
Um dicionário opcional de atribuições de parâmetros de pipeline para o PipelineDraft; necessário apenas ao criar a partir de um arquivo Pipeline. Valor padrão: None
|
continue_on_step_failure
|
Indica se deverá continuar um PipelineRun quando uma execução de etapa falhar na configuração do PipelineDraft; necessário apenas ao criar a partir de um arquivo Pipeline. Valor padrão: None
|
tags
|
Um dicionário de marcas opcional para o PipelineDraft, necessário apenas ao criar a partir de um arquivo Pipeline. Valor padrão: None
|
properties
|
Dicionário de propriedades opcionais para o PipelineDraft, necessário apenas ao criar a partir de um arquivo Pipeline. Valor padrão: None
|
_service_endpoint
|
O ponto de extremidade de serviço. Valor padrão: None
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Somente uso interno.) O provedor de fluxo de trabalho. Valor padrão: None
|
Retornos
Tipo | Description |
---|---|
O PipelineDraft criado. |
delete
Exclui o PipelineDraft.
delete(_workflow_provider=None)
Parâmetros
Nome | Description |
---|---|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Somente uso interno.) O provedor de fluxo de trabalho. Valor padrão: None
|
get
Obtém o PipelineDraft com a ID fornecida.
static get(workspace, id, _workflow_provider=None, _service_endpoint=None)
Parâmetros
Nome | Description |
---|---|
workspace
Obrigatório
|
O workspace no qual o PipelineDraft foi criado. |
id
Obrigatório
|
A ID do PipelineDraft. |
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Somente uso interno.) O provedor de fluxo de trabalho. Valor padrão: None
|
_service_endpoint
|
O ponto de extremidade de serviço. Valor padrão: None
|
Retornos
Tipo | Description |
---|---|
Objeto PipelineDraft |
get_graph
Obter o gráfico associado ao PipelineDraft.
get_graph(_workflow_provider=None)
Parâmetros
Nome | Description |
---|---|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Somente uso interno.) O provedor de fluxo de trabalho. Valor padrão: None
|
Retornos
Tipo | Description |
---|---|
O objeto de gráfico. |
list
Obtém todos os rascunhos de pipeline em um workspace.
static list(workspace, tags=None, _workflow_provider=None)
Parâmetros
Nome | Description |
---|---|
workspace
Obrigatório
|
O workspace do qual listar os rascunhos. |
tags
|
Se especificado, retorna os rascunhos correspondentes ao {"tag": "value"} especificado. Valor padrão: None
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Somente uso interno.) O provedor de fluxo de trabalho. Valor padrão: None
|
Retornos
Tipo | Description |
---|---|
Uma lista de objetos PipelineDraft. |
publish
Publica um PublishedPipeline do PipelineDraft.
publish(_workflow_provider=None)
Parâmetros
Nome | Description |
---|---|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Somente uso interno.) O provedor de fluxo de trabalho. Valor padrão: None
|
Retornos
Tipo | Description |
---|---|
O PublishedPipeline criado. |
save
Salve o YAML do PipelineDraft em um arquivo.
save(path=None, _workflow_provider=None)
Parâmetros
Nome | Description |
---|---|
path
|
O caminho no qual salvar o YAML. Se o caminho for um diretório, o arquivo YAML do PipelineDraft será salvo em path/pipeline_name.yml. Se o caminho for None, será usado o diretório atual. Valor padrão: None
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Somente uso interno.) O provedor de fluxo de trabalho. Valor padrão: None
|
Retornos
Tipo | Description |
---|---|
submit_run
Envia um PipelineRun do PipelineDraft.
submit_run(_workflow_provider=None)
Parâmetros
Nome | Description |
---|---|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Somente uso interno.) O provedor de fluxo de trabalho. Valor padrão: None
|
Retornos
Tipo | Description |
---|---|
O PipelineRun enviado. |
update
Atualiza um PipelineDraft.
Os campos fornecidos serão atualizados.
update(pipeline=None, name=None, description=None, experiment_name=None, tags=None, pipeline_parameters=None, continue_on_step_failure=None, _workflow_provider=None)
Parâmetros
Nome | Description |
---|---|
pipeline
|
O pipeline atualizado para o rascunho. Valor padrão: None
|
name
|
O nome do PipelineDraft. Valor padrão: None
|
description
|
A descrição do PipelineDraft. Valor padrão: None
|
experiment_name
|
O nome do experimento para o PipelineDraft. Valor padrão: None
|
tags
|
Um dicionário de marcas para o PipelineDraft. Valor padrão: None
|
pipeline_parameters
|
As atribuições de parâmetro de pipeline para o PipelineDraft. Valor padrão: None
|
continue_on_step_failure
|
Se deverá continuar PipelineRun quando a execução de uma etapa falhar na configuração do PipelineDraft. Valor padrão: None
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Somente uso interno.) O provedor de fluxo de trabalho. Valor padrão: None
|
Atributos
description
Obtém a descrição do PipelineDraft.
Retornos
Tipo | Description |
---|---|
A cadeia de caracteres da descrição. |
id
last_submitted_pipeline_run_id
Obtém a ID da última PipelineRun enviada do PipelineDraft.
Retornos
Tipo | Description |
---|---|
A ID do PipelineRun. |
name
parent_pipeline_draft_id
Obtém a ID do PipelineDraft pai do PipelineDraft.
Retornos
Tipo | Description |
---|---|
A ID do PipelineDraft. |
parent_pipeline_id
Obtenha a ID do PublishedPipeline pai do PipelineDraft.
Retornos
Tipo | Description |
---|---|
A ID do PublishedPipeline. |
parent_pipeline_run_id
parent_step_run_ids
Obtém a lista das IDs de StepRun do PipelineRun pai do PipelineDraft.
Retornos
Tipo | Description |
---|---|
Uma lista de IDs de StepRun. |
properties
Obtém as propriedades do PipelineDraft.
Retornos
Tipo | Description |
---|---|
O dicionário de propriedades. |