Delen via

PipelineRun Klas

Vertegenwoordigt een uitvoering van een Pipeline.

Deze klasse kan worden gebruikt voor het beheren, controleren van de status en het ophalen van uitvoeringsdetails zodra een pijplijnuitvoering is verzonden. Hiermee get_steps haalt u de StepRun objecten op die zijn gemaakt door de pijplijnuitvoering. Andere toepassingen zijn onder andere het ophalen van het Graph object dat is gekoppeld aan de pijplijnuitvoering, het ophalen van de status van de pijplijnuitvoering en het wachten op voltooiing van de uitvoering.

Initialiseer een pijplijnuitvoering.

Constructor

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

Parameters

Name Description
experiment
Vereist
Experiment

Het experimentobject dat is gekoppeld aan de pijplijnuitvoering.
run_id
Vereist
str

De uitvoerings-id van de pijplijnuitvoering.
_service_endpoint
str

Het eindpunt waarmee verbinding moet worden gemaakt.

Default value: None
experiment
Vereist
Experiment

Het experimentobject dat is gekoppeld aan de pijplijnuitvoering.
run_id
Vereist
str

De uitvoerings-id van de pijplijnuitvoering.
_service_endpoint
Vereist
str

Het eindpunt waarmee verbinding moet worden gemaakt.

Opmerkingen

Er wordt een PipelineRun-object geretourneerd bij het verzenden van een Pipeline via de submit. methode van een Experiment. Zie voor meer informatie over het maken en verzenden van een pijplijn: https://aka.ms/pl-first-pipeline

Een PipelineRun kan ook worden geïnstantieerd met de Experiment uitvoering is verzonden naar en de PipelineRun-id als volgt:


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

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

Wanneer u met PipelineRun werkt, gebruikt u:

  • wait_for_completion om de uitvoeringsstatus te bewaken en eventueel uitvoeringslogboeken te streamen.

  • get_status om de uitvoeringsstatus op te halen.

  • cancel om een doorlopende PipelineRun te annuleren.

  • get_steps om de gegenereerde StepRuns weer te geven. Een PipelineRun genereert een StepRun voor elke stap in de pijplijn.

Methoden

cancel

Annuleer de lopende uitvoering.
child_run

Maak een onderliggende uitvoering voor de pijplijnuitvoering. Deze methode is niet geïmplementeerd voor PipelineRun.
complete

Markeer de pijplijnuitvoering als voltooid. Deze methode is niet geïmplementeerd voor PipelineRun.

Deze methode wordt niet ondersteund voor pijplijnen; voltooiings-/mislukte status wordt beheerd door de Azure ML-back-end.
fail

Markeer de pijplijnuitvoering als mislukt. Deze methode is niet geïmplementeerd voor PipelineRun.

Deze methode wordt niet ondersteund voor pijplijnen; voltooiings-/mislukte status wordt beheerd door de Azure ML-back-end.
find_step_run

Zoek een stap die in de pijplijn op naam wordt uitgevoerd.
get

Haal een pijplijnuitvoering op op basis van een uitvoerings-id.
get_graph

Haal de grafiek van de pijplijnuitvoering op.
get_pipeline_output

Haal de PortDataReference op voor de opgegeven pijplijnuitvoer.
get_pipeline_runs

Haal de pijplijnuitvoeringen op die zijn gegenereerd op basis van een gepubliceerde pijplijn.
get_status

Haal de meest recente status van de pijplijnuitvoering op uit de service.

Algemene waarden die worden geretourneerd, zijn 'Actief', 'Voltooid' en 'Mislukt'.
get_steps

Haal de stapuitvoeringen op voor alle pijplijnstappen die zijn voltooid of die zijn gestart.
get_tags

Haal de set tags voor de uitvoering op.
publish_pipeline

Publiceer een pijplijn en maak deze beschikbaar voor opnieuw uitvoeren.

U kunt het pijplijneindpunt ophalen uit het PublishedPipeline-object dat door deze functie wordt geretourneerd. Met het pijplijneindpunt kunt u de pijplijn aanroepen vanuit externe toepassingen met behulp van REST-aanroepen. Zie voor meer informatie over het verifiëren bij het aanroepen van REST-eindpunten https://aka.ms/pl-restep-auth.

De oorspronkelijke pijplijn die is gekoppeld aan de pijplijnuitvoering, wordt gebruikt als basis voor de gepubliceerde pijplijn.
save

Sla de YAML-pijplijn op in een bestand.
wait_for_completion

Wacht tot de uitvoering van deze pijplijn is voltooid.

Retourneert de status na de wachttijd.

cancel

Annuleer de lopende uitvoering.

cancel()

child_run

Maak een onderliggende uitvoering voor de pijplijnuitvoering. Deze methode is niet geïmplementeerd voor PipelineRun.

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

Parameters

Name Description
name
str

Optionele naam voor het kind.

Default value: None
run_id
str

Optionele uitvoerings-id voor het onderliggende item, anders wordt de standaardwaarde gebruikt.

Default value: None
outputs
str

Optionele uitvoermap die moet worden bijgehouden voor het onderliggende item.

Default value: None

Retouren

Type Description
Run

Het onderliggende item wordt uitgevoerd.

Uitzonderingen

Type Description
NotImplementedError

complete

Markeer de pijplijnuitvoering als voltooid. Deze methode is niet geïmplementeerd voor PipelineRun.

Deze methode wordt niet ondersteund voor pijplijnen; voltooiings-/mislukte status wordt beheerd door de Azure ML-back-end.

complete()

Uitzonderingen

Type Description
NotImplementedError

fail

Markeer de pijplijnuitvoering als mislukt. Deze methode is niet geïmplementeerd voor PipelineRun.

Deze methode wordt niet ondersteund voor pijplijnen; voltooiings-/mislukte status wordt beheerd door de Azure ML-back-end.

fail()

Uitzonderingen

Type Description
NotImplementedError

find_step_run

Zoek een stap die in de pijplijn op naam wordt uitgevoerd.

find_step_run(name)

Parameters

Name Description
name
Vereist
str

De naam van de stap die u wilt zoeken.

Retouren

Type Description
list

Lijst met StepRun objecten met de opgegeven naam.

get

Haal een pijplijnuitvoering op op basis van een uitvoerings-id.

static get(workspace, run_id, _service_endpoint=None)

Parameters

Name Description
workspace
Vereist
Workspace

De werkruimte die is gekoppeld aan de pijplijn.
run_id
Vereist
str

De id van de pijplijnuitvoering.
_service_endpoint
str

Het eindpunt waarmee verbinding moet worden gemaakt.

Default value: None

Retouren

Type Description
PipelineRun

Het PipelineRun-object.

get_graph

Haal de grafiek van de pijplijnuitvoering op.

get_graph()

Retouren

Type Description
Graph

De grafiek.

get_pipeline_output

Haal de PortDataReference op voor de opgegeven pijplijnuitvoer.

get_pipeline_output(pipeline_output_name)

Parameters

Name Description
pipeline_output_name
Vereist
str

De naam van de pijplijnuitvoer die u wilt ophalen.

Retouren

Type Description
PortDataReference

De PortDataReference die de pijplijnuitvoergegevens vertegenwoordigt.

get_pipeline_runs

Haal de pijplijnuitvoeringen op die zijn gegenereerd op basis van een gepubliceerde pijplijn.

static get_pipeline_runs(workspace, pipeline_id, _service_endpoint=None)

Parameters

Name Description
workspace
Vereist
Workspace

De werkruimte die is gekoppeld aan de pijplijn.
pipeline_id
Vereist
str

De id van de gepubliceerde pijplijn.
_service_endpoint
str

Het eindpunt waarmee verbinding moet worden gemaakt.

Default value: None

Retouren

Type Description
list

Een lijst PipelineRun met objecten.

get_status

Haal de meest recente status van de pijplijnuitvoering op uit de service.

Algemene waarden die worden geretourneerd, zijn 'Actief', 'Voltooid' en 'Mislukt'.

get_status()

Retouren

Type Description
str

De meest recente status als een tekenreeks.

Opmerkingen

  • NotStarted - Dit is een tijdelijke status run-objecten aan clientzijde die zich bevinden vóór het verzenden van de cloud

  • Wordt uitgevoerd: de taak is gestart om te worden uitgevoerd in het rekendoel.

  • Mislukt: de uitvoering is mislukt. Meestal bevat de eigenschap Fout bij een uitvoering details over waarom.

  • Voltooid: de uitvoering is voltooid.

  • Geannuleerd: na annuleringsaanvraag wordt de uitvoering nu geannuleerd.


   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

Haal de stapuitvoeringen op voor alle pijplijnstappen die zijn voltooid of die zijn gestart.

get_steps()

Retouren

Type Description
list

Een lijst StepRun met objecten.

get_tags

Haal de set tags voor de uitvoering op.

get_tags()

Retouren

Type Description
dict

De woordenlijst met tags voor de uitvoering.

publish_pipeline

Publiceer een pijplijn en maak deze beschikbaar voor opnieuw uitvoeren.

U kunt het pijplijneindpunt ophalen uit het PublishedPipeline-object dat door deze functie wordt geretourneerd. Met het pijplijneindpunt kunt u de pijplijn aanroepen vanuit externe toepassingen met behulp van REST-aanroepen. Zie voor meer informatie over het verifiëren bij het aanroepen van REST-eindpunten https://aka.ms/pl-restep-auth.

De oorspronkelijke pijplijn die is gekoppeld aan de pijplijnuitvoering, wordt gebruikt als basis voor de gepubliceerde pijplijn.

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

Parameters

Name Description
name
Vereist
str

De naam van de gepubliceerde pijplijn.
description
Vereist
str

De beschrijving van de gepubliceerde pijplijn.
version
Vereist
str

De versie van de gepubliceerde pijplijn.
continue_on_step_failure
bool

Of u wilt doorgaan met het uitvoeren van andere stappen in PipelineRun als een stap mislukt. De standaardwaarde is Onwaar.

Default value: None
kwargs
Vereist
dict

Aangepaste trefwoordargumenten, gereserveerd voor toekomstige ontwikkeling

Retouren

Type Description
PublishedPipeline

Gepubliceerde pijplijn gemaakt.

save

Sla de YAML-pijplijn op in een bestand.

save(path=None)

Parameters

Name Description
path
str

Het pad naar het opslaan van de YAML. Als het pad een map is, wordt het YAML-pijplijnbestand opgeslagen op <pad>/pipeline.yml. Als het pad geen is, wordt de huidige map gebruikt.

Default value: None

Retouren

Type Description
None

wait_for_completion

Wacht tot de uitvoering van deze pijplijn is voltooid.

Retourneert de status na de wachttijd.

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

Parameters

Name Description
show_output
bool

Geeft aan of de uitvoeringsstatus van de pijplijn moet worden weergegeven op sys.stdout.

Default value: True
timeout_seconds
int

Het aantal seconden dat moet worden gewacht voordat er een time-out optreedt.

Default value: 9223372036854775807
raise_on_error
bool

Hiermee wordt aangegeven of er een fout wordt gegenereerd wanneer de uitvoering de status Mislukt heeft.

Default value: True

Retouren

Type Description
str

De laatste status.