PipelineDraft Clase
Representa una canalización mutable que se puede usar para enviar ejecuciones y crear canalizaciones publicadas.
Use PipelineDrafts para iterar en canalizaciones. PipelineDrafts se puede crear desde cero, otra pipelineDraft o canalizaciones existentes: Pipeline, PublishedPipelineo PipelineRun.
Inicializar PipelineDraft.
Constructor
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
| Nombre | Description |
|---|---|
|
workspace
Requerido
|
Objeto de área de trabajo para esta PipelineDraft. |
|
id
Requerido
|
Identificador de PipelineDraft. |
|
name
Requerido
|
Nombre de PipelineDraft. |
|
description
Requerido
|
Descripción de PipelineDraft. |
|
experiment_name
Requerido
|
Nombre del experimento para PipelineDraft. |
|
tags
Requerido
|
Diccionario de etiquetas opcionales para PipelineDraft. |
|
properties
Requerido
|
Diccionario de propiedades opcionales para PipelineDraft. |
|
graph_draft_id
Requerido
|
Identificador del borrador del grafo asociado a PipelineDraft. |
|
parent_pipeline_id
Requerido
|
Identificador del elemento primario PublishedPipeline. |
|
parent_pipeline_run_id
Requerido
|
Identificador de pipelineRun primario. |
|
parent_step_run_ids
Requerido
|
Lista de los id. de StepRun del pipelineRun primario. |
|
parent_pipeline_draft_id
Requerido
|
El identificador de PipelineDraft primario. |
|
last_submitted_pipeline_run_id
Requerido
|
Identificador del último pipelineRun enviado. |
|
_pipeline_draft_provider
Requerido
|
<xref:azureml.pipeline.core._aeva_provider._AevaPipelineDraftProvider>
(Solo uso interno). Proveedor PipelineDraft. |
|
workspace
Requerido
|
Objeto workspace para este PipelineDraft. |
|
id
Requerido
|
Identificador de PipelineDraft. |
|
name
Requerido
|
Nombre de PipelineDraft. |
|
description
Requerido
|
Descripción de PipelineDraft. |
|
experiment_name
Requerido
|
Nombre del experimento para PipelineDraft. |
|
tags
Requerido
|
Diccionario de etiquetas para PipelineDraft. |
|
properties
Requerido
|
Diccionario de propiedades para PipelineDraft. |
|
graph_draft_id
Requerido
|
Identificador del borrador del grafo asociado a PipelineDraft. |
|
parent_pipeline_id
Requerido
|
Identificador del elemento primario PublishedPipeline. |
|
parent_pipeline_run_id
Requerido
|
Identificador de pipelineRun primario. |
|
parent_step_run_ids
Requerido
|
Lista de los identificadores StepRun de PipelineRun primarios. |
|
parent_pipeline_draft_id
Requerido
|
Identificador de pipelineDraft primario. |
|
last_submitted_pipeline_run_id
Requerido
|
Identificador del último pipelineRun enviado. |
|
_pipeline_draft_provider
Requerido
|
<xref:azureml.pipeline.core._aeva_provider._AevaPipelineDraftProvider>
Proveedor PipelineDraft. |
Comentarios
Una pipelineDraft se puede crear a partir de mediante Pipeline la create función . A continuación se muestra un ejemplo:
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'})
El parámetro de canalización PipelineDraft.create()también puede ser , PublishedPipelinePipelineRunu otro PipelineDraft.
Para enviar una ejecución desde pipelineDraft, use el submit_run método :
pipeline_run = pipeline_draft.submit_run()
Para actualizar pipelineDraft, use el update método . La función update() de un borrador de canalización se puede usar para actualizar el nombre, la descripción, el nombre del experimento, las asignaciones de parámetros de canalización, continuar en la configuración del error del paso y canalización asociada a 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 |
Cree una pipelineDraft. |
| delete |
Elimine PipelineDraft. |
| get |
Obtenga PipelineDraft con el identificador especificado. |
| get_graph |
Obtenga el gráfico asociado a PipelineDraft. |
| list |
Obtenga todos los borradores de canalización en un área de trabajo. |
| publish |
Publique una propiedad PublishedPipeline desde PipelineDraft. |
| save |
Guarde pipelineDraft YAML en un archivo. |
| submit_run |
Envíe una pipelineRun desde PipelineDraft. |
| update |
Actualice pipelineDraft. Los campos proporcionados se actualizarán. |
create
Cree una 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
| Nombre | Description |
|---|---|
|
workspace
Requerido
|
Objeto de área de trabajo al que pertenecerá PipelineDraft. |
|
pipeline
Requerido
|
Canalización o canalización publicada. |
|
name
|
Nombre de PipelineDraft; solo es necesario al crear a partir de .Pipeline Valor predeterminado: None
|
|
description
|
Descripción de PipelineDraft; solo es necesario al crear a partir de .Pipeline Valor predeterminado: None
|
|
experiment_name
|
Nombre del experimento para PipelineDraft; solo es necesario al crear a partir de .Pipeline Valor predeterminado: None
|
|
pipeline_parameters
|
Diccionario opcional de asignaciones de parámetros de canalización para PipelineDraft; solo es necesario al crear a partir de .Pipeline Valor predeterminado: None
|
|
continue_on_step_failure
|
Indica si se va a continuar una pipelineRun cuando se produce un error en una ejecución de pasos para PipelineDraft; solo es necesario al crear a partir de .Pipeline Valor predeterminado: None
|
|
tags
|
Un diccionario de etiquetas opcionales para PipelineDraft, solo es necesario al crear a partir de .Pipeline Valor predeterminado: None
|
|
properties
|
Diccionario de propiedades opcionales para PipelineDraft, solo es necesario al crear a partir de .Pipeline Valor predeterminado: None
|
|
_service_endpoint
|
Punto de conexión de servicio. Valor predeterminado: None
|
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Solo uso interno). Proveedor de flujo de trabajo. Valor predeterminado: None
|
Devoluciones
| Tipo | Description |
|---|---|
|
PipelineDraft creado. |
delete
Elimine PipelineDraft.
delete(_workflow_provider=None)
Parámetros
| Nombre | Description |
|---|---|
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Solo uso interno). Proveedor de flujo de trabajo. Valor predeterminado: None
|
get
Obtenga PipelineDraft con el identificador especificado.
static get(workspace, id, _workflow_provider=None, _service_endpoint=None)
Parámetros
| Nombre | Description |
|---|---|
|
workspace
Requerido
|
Área de trabajo en la que se creó PipelineDraft. |
|
id
Requerido
|
Identificador de PipelineDraft. |
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Solo uso interno). Proveedor de flujo de trabajo. Valor predeterminado: None
|
|
_service_endpoint
|
Punto de conexión de servicio. Valor predeterminado: None
|
Devoluciones
| Tipo | Description |
|---|---|
|
PipelineDraft (objeto) |
get_graph
Obtenga el gráfico asociado a PipelineDraft.
get_graph(_workflow_provider=None)
Parámetros
| Nombre | Description |
|---|---|
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Solo uso interno). Proveedor de flujo de trabajo. Valor predeterminado: None
|
Devoluciones
| Tipo | Description |
|---|---|
|
Objeto Graph. |
list
Obtenga todos los borradores de canalización en un área de trabajo.
static list(workspace, tags=None, _workflow_provider=None)
Parámetros
| Nombre | Description |
|---|---|
|
workspace
Requerido
|
Área de trabajo desde la que se van a enumerar los borradores. |
|
tags
|
Si se especifica, devuelve borradores coincidentes especificados {"tag": "value"}. Valor predeterminado: None
|
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Solo uso interno). Proveedor de flujo de trabajo. Valor predeterminado: None
|
Devoluciones
| Tipo | Description |
|---|---|
|
Lista de PipelineDraft objetos. |
publish
Publique una propiedad PublishedPipeline desde PipelineDraft.
publish(_workflow_provider=None)
Parámetros
| Nombre | Description |
|---|---|
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Solo uso interno). Proveedor de flujo de trabajo. Valor predeterminado: None
|
Devoluciones
| Tipo | Description |
|---|---|
|
El objeto PublishedPipeline creado. |
save
Guarde pipelineDraft YAML en un archivo.
save(path=None, _workflow_provider=None)
Parámetros
| Nombre | Description |
|---|---|
|
path
|
Ruta de acceso a la que se va a guardar YAML. Si la ruta de acceso es un directorio, el archivo YAML pipelineDraft se guarda en la ruta de acceso o pipeline_name.yml. Si la ruta de acceso es None, se usa el directorio actual. Valor predeterminado: None
|
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Solo uso interno). Proveedor de flujo de trabajo. Valor predeterminado: None
|
Devoluciones
| Tipo | Description |
|---|---|
submit_run
Envíe una pipelineRun desde PipelineDraft.
submit_run(_workflow_provider=None)
Parámetros
| Nombre | Description |
|---|---|
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Solo uso interno). Proveedor de flujo de trabajo. Valor predeterminado: None
|
Devoluciones
| Tipo | Description |
|---|---|
|
PipelineRun enviado. |
update
Actualice pipelineDraft.
Los campos proporcionados se actualizarán.
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
| Nombre | Description |
|---|---|
|
pipeline
|
Canalización actualizada para el borrador. Valor predeterminado: None
|
|
name
|
Nombre de PipelineDraft. Valor predeterminado: None
|
|
description
|
Descripción de PipelineDraft. Valor predeterminado: None
|
|
experiment_name
|
Nombre del experimento para PipelineDraft. Valor predeterminado: None
|
|
tags
|
Diccionario de etiquetas para PipelineDraft. Valor predeterminado: None
|
|
pipeline_parameters
|
Asignaciones de parámetros de canalización para PipelineDraft. Valor predeterminado: None
|
|
continue_on_step_failure
|
Si desea continuar pipelineRun cuando se produce un error en una ejecución de pasos para PipelineDraft. Valor predeterminado: None
|
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
(Solo uso interno). Proveedor de flujo de trabajo. Valor predeterminado: None
|
Atributos
description
id
last_submitted_pipeline_run_id
Obtenga el identificador del último pipelineRun enviado de PipelineDraft.
Devoluciones
| Tipo | Description |
|---|---|
|
El identificador pipelineRun. |
name
parent_pipeline_draft_id
Obtenga el identificador de pipelineDraft primario de PipelineDraft.
Devoluciones
| Tipo | Description |
|---|---|
|
Identificador de PipelineDraft. |
parent_pipeline_id
Obtenga el identificador del elemento primario PublishedPipeline de PipelineDraft.
Devoluciones
| Tipo | Description |
|---|---|
|
Identificador de PublishedPipeline. |
parent_pipeline_run_id
Obtenga el identificador de pipelineRun primario de PipelineDraft.
Devoluciones
| Tipo | Description |
|---|---|
|
El identificador pipelineRun. |
parent_step_run_ids
Obtenga la lista de identificadores StepRun de pipelineRun primarios de PipelineDraft.
Devoluciones
| Tipo | Description |
|---|---|
|
Lista de identificadores StepRun. |
properties
Obtenga las propiedades de PipelineDraft.
Devoluciones
| Tipo | Description |
|---|---|
|
Diccionario de propiedades. |
tags
Obtenga las etiquetas de PipelineDraft.
Devoluciones
| Tipo | Description |
|---|---|
|
Diccionario de etiquetas. |