Dela via

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.

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

Name Description
experiment
Obligatorisk
Experiment

Experimentobjektet för stegkörningen.
step_run_id
Obligatorisk
str

Körnings-ID för stegkörningen.
pipeline_run_id
Obligatorisk
str

Körnings-ID för den överordnade pipelinekörningen.
node_id
Obligatorisk
str

ID:t för noden i diagrammet som representerar det här steget.
_service_endpoint
str

Slutpunkten som du vill ansluta till.

Standardvärde: None
_is_reused
bool

Anger om den här körningen är en återanvänd tidigare körning.

Standardvärde: False
_current_node_id
str

För en återanvänd nod, nod-ID i den aktuella grafen.

Standardvärde: None
_reused_run_id
str

Det återanvända körnings-ID:t.

Standardvärde: None
_reused_node_id
str

Det återanvända nod-ID:t.

Standardvärde: None
_reused_pipeline_run_id
str

Det återanvända pipeline-ID:t.

Standardvärde: None
experiment
Obligatorisk
Experiment

Experimentobjektet för stegkörningen.
step_run_id
Obligatorisk
str

Körnings-ID för stegkörningen.
pipeline_run_id
Obligatorisk
str

Körnings-ID för den överordnade pipelinekörningen.
node_id
Obligatorisk
str

ID:t för noden i diagrammet som representerar det här steget.
_service_endpoint
Obligatorisk
str

Slutpunkten som du vill ansluta till.
_is_reused
Obligatorisk
bool

Anger om den här körningen är en återanvänd tidigare körning.
_current_node_id
Obligatorisk
str

För en återanvänd nod, nod-ID i den aktuella grafen.
_reused_run_id
Obligatorisk
_reused_node_id
Obligatorisk
str
_reused_pipeline_run_id
Obligatorisk
str

Kommentarer

En StepRun skapas som en underordnad körning av en skickad PipelineRun. Hämta alla StepRuns i en PipelineRun enligt följande:


   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 dikta 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 ett 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

Det gick inte att köra steg. Den här metoden har inte implementerats för StepRun.
get_details_with_logs

Returnera statusinformationen för körningen med loggfilens innehå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 den här stegkörningen har slutförts.

Returnerar statusen efter väntan.

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

Name Description
name
str

Valfritt namn på underordnad

Standardvärde: None
run_id
str

Valfritt run_id för det underordnade, annars används standard

Standardvärde: None
outputs
str

Valfri utdatakatalog som ska spåras för den underordnade

Standardvärde: None

Returer

Typ Description
Run

Den underordnade körningen

Undantag

Typ Description
NotImplementedError

complete

Slutför för stegkörning. Den här metoden har inte implementerats för StepRun.

complete()

Undantag

Typ Description
NotImplementedError

fail

Det gick inte att köra steg. Den här metoden har inte implementerats för StepRun.

fail()

Undantag

Typ Description
NotImplementedError

get_details_with_logs

Returnera statusinformationen för körningen med loggfilens innehåll.

get_details_with_logs()

Returer

Typ Description
dict

Returnerar status för körningen med loggfilens innehåll

get_job_log

Dumpa den aktuella jobbloggen för stegkörningen.

get_job_log()

Returer

Typ Description
str

Loggsträngen.

get_output

Hämta nodutdata med det angivna namnet.

get_output(name)

Parametrar

Name Description
name
Obligatorisk
str

Namnet på utdata.

Returer

Typ Description
StepRunOutput

StepRunOutput med det angivna namnet.

get_output_data

Hämta utdata från en viss utdata.

get_output_data(name)

Parametrar

Name Description
name
Obligatorisk
str

Namnet på utdata.

Returer

Typ Description
PortDataReference

PortDataReference som representerar stegutdata.

get_outputs

Hämta stegutdata.

get_outputs()

Returer

Typ Description
dict

En ordlista med StepRunOutputs med utdatanamnet som nyckel.

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

Typ Description
str

Den senaste statusen som en sträng

Kommentarer

  • NotStarted – det här är ett tillfälligt tillstånd för körningsobjekt på klientsidan innan molnöverföring

  • I kö – jobbet placeras 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.

  • Slutförd – körningen har slutförts.

  • Avbröts – Efter 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

Typ Description
str

Loggsträngen.

get_stdout_log

Dumpa den aktuella stdout-loggen för stegkörningen.

get_stdout_log()

Returer

Typ Description
str

Loggsträngen.

wait_for_completion

Vänta tills den här stegkörningen har slutförts.

Returnerar statusen efter väntan.

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

Parametrar

Name Description
show_output
bool

show_output=Sant visar status för pipelinekörning på sys.stdout.

Standardvärde: True
timeout_seconds
int

Antal sekunder att vänta innan tidsgränsen är slut.

Standardvärde: 9223372036854775807
raise_on_error
bool

Anger om ett fel ska uppstå när Körningen är i ett feltillstånd

Standardvärde: True

Returer

Typ Description
str

Den slutliga statusen.

Attribut

pipeline_run_id

Returnera id:t för pipelinekörningen som motsvarar den här stegkörningen.

Returer

Typ Description
str

PipelineRun-ID:t.