StepRun Classe
Esecuzione di un passaggio in un oggetto Pipeline.
Questa classe può essere usata per gestire, controllare lo stato e recuperare i dettagli dell'esecuzione dopo l'invio dell'esecuzione della pipeline padre e la pipeline ha inviato l'esecuzione del passaggio.
Inizializzare un'istruzione StepRun.
- Ereditarietà
-
StepRun
Costruttore
StepRun(experiment, step_run_id, pipeline_run_id, node_id, _service_endpoint=None, _is_reused=False, _current_node_id=None, _reused_run_id=None, _reused_node_id=None, _reused_pipeline_run_id=None, **kwargs)Parametri
- _is_reused
- bool
Indica se questa esecuzione è un'esecuzione precedente riutilizzata.
- _current_node_id
- str
Per un nodo riutilizzato, l'ID del nodo nel grafico corrente.
- _reused_run_id
- _reused_node_id
- str
- _reused_pipeline_run_id
- str
Commenti
Un elemento StepRun viene creato come esecuzione figlio di un oggetto inviato PipelineRun. Recuperare tutte le operazioni StepRun in un oggetto PipelineRun come indicato di seguito:
from azureml.core import Experiment
from azureml.pipeline.core import PipelineRun
experiment = Experiment(workspace, "<experiment_name>")
pipeline_run = PipelineRun(experiment, "<pipeline_run_id>")
step_runs = pipeline_run.get_steps()
Usare get_details_with_logs per recuperare i dettagli dell'esecuzione e i log creati dall'esecuzione.
È anche possibile usare StepRun per scaricare gli output di un'esecuzione. Usare get_outputs per recuperare un valore dict degli output del passaggio oppure usare get_output per recuperare il singolo StepRunOutput oggetto per l'output con il nome specificato. È anche possibile usare get_output_data per recuperare direttamente l'oggetto PortDataReference per l'output del passaggio specificato.
Di seguito è riportato un esempio di download dell'output di un passaggio:
from azureml.pipeline.core import PipelineRun, StepRun, PortDataReference
pipeline_run = PipelineRun(experiment, "<pipeline_run_id>")
step_run = pipeline_run.find_step_run("<step_name>")[0]
port_data_reference = step_run.get_output_data("<output_name>")
port_data_reference.download(local_path="path")
Metodi
| child_run |
Esecuzione figlio per l'esecuzione del passaggio. Questo metodo non è implementato per StepRun. |
| complete |
Completamento per l'esecuzione del passaggio. Questo metodo non è implementato per StepRun. |
| fail |
Esito negativo per l'esecuzione del passaggio. Questo metodo non è implementato per StepRun. |
| get_details_with_logs |
Restituisce i dettagli sullo stato dell'esecuzione con il contenuto del file di log. |
| get_job_log |
Eseguire il dump del log del processo corrente per l'esecuzione del passaggio. |
| get_output |
Ottenere l'output del nodo con il nome specificato. |
| get_output_data |
Ottenere i dati di output da un determinato output. |
| get_outputs |
Ottenere gli output dei passaggi. |
| get_status |
Recuperare lo stato più recente dell'esecuzione della pipeline dal servizio. I valori comuni restituiti includono "Running", "Finished" e "Failed". |
| get_stderr_log |
Eseguire il dump del log stderr corrente per l'esecuzione del passaggio. |
| get_stdout_log |
Eseguire il dump del log stdout corrente per l'esecuzione del passaggio. |
| wait_for_completion |
Attendere il completamento dell'esecuzione di questo passaggio. Restituisce lo stato dopo l'attesa. |
child_run
Esecuzione figlio per l'esecuzione del passaggio. Questo metodo non è implementato per StepRun.
child_run(name=None, run_id=None, outputs=None)Parametri
- run_id
- str
Run_id facoltativo per l'elemento figlio; in caso contrario, usa l'impostazione predefinita
- outputs
- str
Directory di output facoltativa da tenere traccia per l'elemento figlio
Restituisce
Esecuzione figlio
Tipo restituito
Eccezioni
complete
Completamento per l'esecuzione del passaggio. Questo metodo non è implementato per StepRun.
complete()Eccezioni
fail
Esito negativo per l'esecuzione del passaggio. Questo metodo non è implementato per StepRun.
fail()Eccezioni
get_details_with_logs
Restituisce i dettagli sullo stato dell'esecuzione con il contenuto del file di log.
get_details_with_logs()Restituisce
Restituisce lo stato dell'esecuzione con il contenuto del file di log
Tipo restituito
Eccezioni
get_job_log
Eseguire il dump del log del processo corrente per l'esecuzione del passaggio.
get_job_log()Restituisce
Stringa di log.
Tipo restituito
Eccezioni
get_output
Ottenere l'output del nodo con il nome specificato.
get_output(name)Parametri
Restituisce
StepRunOutput con il nome specificato.
Tipo restituito
Eccezioni
get_output_data
Ottenere i dati di output da un determinato output.
get_output_data(name)Parametri
Restituisce
PortDataReference che rappresenta i dati di output del passaggio.
Tipo restituito
Eccezioni
get_outputs
Ottenere gli output dei passaggi.
get_outputs()Restituisce
Dizionario di StepRunOutputs con il nome di output come chiave.
Tipo restituito
Eccezioni
get_status
Recuperare lo stato più recente dell'esecuzione della pipeline dal servizio.
I valori comuni restituiti includono "Running", "Finished" e "Failed".
get_status()Restituisce
Stato più recente come stringa
Tipo restituito
Eccezioni
Commenti
NotStarted: si tratta di oggetti Run sul lato client di stato temporanei che si trovano prima dell'invio nel cloud
Accodato: il processo viene accodato.
In esecuzione: il processo è stato avviato per l'esecuzione nella destinazione di calcolo.
Non riuscito: l'esecuzione non è riuscita. In genere la proprietà Error in un'esecuzione fornirà informazioni dettagliate sul motivo.
Completato: l'esecuzione è stata completata correttamente.
Annullata: dopo la richiesta di annullamento, l'esecuzione viene annullata.
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_stderr_log
Eseguire il dump del log stderr corrente per l'esecuzione del passaggio.
get_stderr_log()Restituisce
Stringa di log.
Tipo restituito
Eccezioni
get_stdout_log
Eseguire il dump del log stdout corrente per l'esecuzione del passaggio.
get_stdout_log()Restituisce
Stringa di log.
Tipo restituito
Eccezioni
wait_for_completion
Attendere il completamento dell'esecuzione di questo passaggio.
Restituisce lo stato dopo l'attesa.
wait_for_completion(show_output=True, timeout_seconds=9223372036854775807, raise_on_error=True)Parametri
- show_output
- bool
show_output=True mostra lo stato di esecuzione della pipeline in sys.stdout.
- timeout_seconds
- int
Numero di secondi di attesa prima del timeout.
- raise_on_error
- bool
Indica se generare un errore quando l'esecuzione si trova in uno stato di errore
Restituisce
Stato finale.
Tipo restituito
Eccezioni
Attributi
pipeline_run_id
Restituisce l'ID dell'esecuzione della pipeline corrispondente a questo passaggio.
Restituisce
ID PipelineRun.
Tipo restituito
Commenti e suggerimenti
Presto disponibile: Nel corso del 2024 verranno gradualmente disattivati i problemi di GitHub come meccanismo di feedback per il contenuto e ciò verrà sostituito con un nuovo sistema di feedback. Per altre informazioni, vedere https://aka.ms/ContentUserFeedback.
Invia e visualizza il feedback per