StepRun Klass
En körning av ett steg i en Pipeline.
Den här klassen kan användas för att hantera, kontrollera status och hämta körningsinformation när den överordnade pipelinekörningen har skickats och pipelinen har skickat stegkörningen.
Initiera en StepRun.
- Arv
-
StepRun
Konstruktor
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)
Parametrar
- _reused_run_id
- _reused_node_id
- str
- _reused_pipeline_run_id
- str
Kommentarer
En StepRun skapas som en underordnad körning av en skickad PipelineRun. Hämta alla StepRuns i en PipelineKör på följande sätt:
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()
Använd get_details_with_logs för att hämta körningsinformationen och loggarna som skapats av körningen.
StepRun kan också användas för att ladda ned utdata från en körning. Använd get_outputs för att hämta en diktering av stegutdata, eller använd get_output för att hämta det enskilda StepRunOutput objektet för utdata med det angivna namnet. Du kan också använda get_output_data för att hämta PortDataReference för de angivna stegutdata direkt.
Ett exempel på hur du laddar ned stegutdata är följande:
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")
Metoder
child_run |
Underordnad körning för stegkörning. Den här metoden har inte implementerats för StepRun. |
complete |
Slutför för stegkörning. Den här metoden har inte implementerats för StepRun. |
fail |
Misslyckas för stegkörning. Den här metoden har inte implementerats för StepRun. |
get_details_with_logs |
Returnera statusinformationen för körningen med loggfilsinnehåll. |
get_job_log |
Dumpa den aktuella jobbloggen för stegkörningen. |
get_output |
Hämta nodutdata med det angivna namnet. |
get_output_data |
Hämta utdata från en viss utdata. |
get_outputs |
Hämta stegutdata. |
get_status |
Hämta pipelinekörningens senaste status från tjänsten. Vanliga värden som returneras är "Running", "Finished" och "Failed". |
get_stderr_log |
Dumpa den aktuella stderr-loggen för stegkörningen. |
get_stdout_log |
Dumpa den aktuella stdout-loggen för stegkörningen. |
wait_for_completion |
Vänta tills det här steget har körts. Returnerar statusen efter väntetiden. |
child_run
Underordnad körning för stegkörning. Den här metoden har inte implementerats för StepRun.
child_run(name=None, run_id=None, outputs=None)
Parametrar
Returer
Den underordnade körningen
Returtyp
Undantag
complete
Slutför för stegkörning. Den här metoden har inte implementerats för StepRun.
complete()
Undantag
fail
Misslyckas för stegkörning. Den här metoden har inte implementerats för StepRun.
fail()
Undantag
get_details_with_logs
Returnera statusinformationen för körningen med loggfilsinnehåll.
get_details_with_logs()
Returer
Returnerar status för körningen med loggfilsinnehåll
Returtyp
Undantag
get_job_log
Dumpa den aktuella jobbloggen för stegkörningen.
get_job_log()
Returer
Loggsträngen.
Returtyp
Undantag
get_output
Hämta nodutdata med det angivna namnet.
get_output(name)
Parametrar
Returer
StepRunOutput med det angivna namnet.
Returtyp
Undantag
get_output_data
Hämta utdata från en viss utdata.
get_output_data(name)
Parametrar
Returer
PortDataReference som representerar stegets utdata.
Returtyp
Undantag
get_outputs
Hämta stegutdata.
get_outputs()
Returer
En ordlista med StepRunOutputs med utdatanamnet som nyckel.
Returtyp
Undantag
get_status
Hämta pipelinekörningens senaste status från tjänsten.
Vanliga värden som returneras är "Running", "Finished" och "Failed".
get_status()
Returer
Den senaste statusen som en sträng
Returtyp
Undantag
Kommentarer
NotStarted – det här är ett tillfälligt tillstånd för körningsobjekt på klientsidan innan molnöverföring
I kö – jobbet har placerats i kö.
Körs – jobbet började köras i beräkningsmålet.
Misslyckades – körningen misslyckades. Vanligtvis innehåller egenskapen Error på en körning information om varför.
Klar – körningen har slutförts.
Avbruten – Efter en annulleringsbegäran avbryts körningen nu.
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
Dumpa den aktuella stderr-loggen för stegkörningen.
get_stderr_log()
Returer
Loggsträngen.
Returtyp
Undantag
get_stdout_log
Dumpa den aktuella stdout-loggen för stegkörningen.
get_stdout_log()
Returer
Loggsträngen.
Returtyp
Undantag
wait_for_completion
Vänta tills det här steget har körts.
Returnerar statusen efter väntetiden.
wait_for_completion(show_output=True, timeout_seconds=9223372036854775807, raise_on_error=True)
Parametrar
- show_output
- bool
show_output=True visar status för pipelinekörningen på sys.stdout.
- timeout_seconds
- int
Antal sekunder att vänta innan tidsgränsen nås.
- raise_on_error
- bool
Anger om ett fel ska utlösas när körningen är i ett feltillstånd
Returer
Den slutliga statusen.
Returtyp
Undantag
Attribut
pipeline_run_id
Returnera ID:t för pipelinekörningen som motsvarar den här stegkörningen.
Returer
PipelineKör id.
Returtyp
Feedback
https://aka.ms/ContentUserFeedback.
Kommer snart: Under hela 2024 kommer vi att fasa ut GitHub-problem som feedbackmekanism för innehåll och ersätta det med ett nytt feedbacksystem. Mer information finns i:Skicka och visa feedback för