Share via

StepRun Sınıf

  • Başvuru

içinde bir adım çalıştırması Pipeline.

Bu sınıf, üst işlem hattı çalıştırması gönderildikten ve işlem hattı adım çalıştırmasını gönderdikten sonra çalıştırma ayrıntılarını yönetmek, denetlemek ve almak için kullanılabilir.

StepRun başlatma.

Devralma
Run
StepRun

Oluşturucu

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)

Parametreler

Name Description
experiment
Gerekli
Experiment

Adımın deneme nesnesi çalıştırılır.
step_run_id
Gerekli
str

Adım çalıştırmasının çalıştırma kimliği.
pipeline_run_id
Gerekli
str

Üst işlem hattı çalıştırmasının çalıştırma kimliği.
node_id
Gerekli
str

Grafikte bu adımı temsil eden düğümün kimliği.
_service_endpoint
str

Bağlanacak uç nokta.

varsayılan değer: None
_is_reused
bool

Bu çalıştırmanın yeniden kullanılan bir önceki çalıştırma olup olmadığını gösterir.

varsayılan değer: False
_current_node_id
str

Yeniden kullanılan bir düğüm için geçerli grafikteki düğüm kimliği.

varsayılan değer: None
_reused_run_id
str

Yeniden kullanılan çalıştırma kimliği.

varsayılan değer: None
_reused_node_id
str

Yeniden kullanılan düğüm kimliği.

varsayılan değer: None
_reused_pipeline_run_id
str

Yeniden kullanılan işlem hattı kimliği.

varsayılan değer: None
experiment
Gerekli
Experiment

Adımın deneme nesnesi çalıştırılır.
step_run_id
Gerekli
str

Adım çalıştırmasının çalıştırma kimliği.
pipeline_run_id
Gerekli
str

Üst işlem hattı çalıştırmasının çalıştırma kimliği.
node_id
Gerekli
str

Grafikte bu adımı temsil eden düğümün kimliği.
_service_endpoint
Gerekli
str

Bağlanacak uç nokta.
_is_reused
Gerekli
bool

Bu çalıştırmanın yeniden kullanılan bir önceki çalıştırma olup olmadığını gösterir.
_current_node_id
Gerekli
str

Yeniden kullanılan bir düğüm için geçerli grafikteki düğüm kimliği.
_reused_run_id
Gerekli
_reused_node_id
Gerekli
str
_reused_pipeline_run_id
Gerekli
str

Açıklamalar

Gönderilen PipelineRunbir öğesinin alt çalıştırması olarak bir StepRun oluşturulur. Bir PipelineRun içindeki tüm StepRun'ları aşağıdaki gibi getirin:


   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()

Çalıştırma tarafından oluşturulan çalıştırma ayrıntılarını ve günlüklerini getirmek için kullanın get_details_with_logs .

StepRun, çalıştırmanın çıkışlarını indirmek için de kullanılabilir. get_outputs Adım çıkışlarının bir diktini almak için kullanın veya sağlanan ada sahip çıkışın tek StepRunOutput nesnesini almak için kullanınget_output. Ayrıca, belirtilen adım çıkışı için öğesini doğrudan getirmek PortDataReference için de kullanabilirsinizget_output_data.

Adım çıkışını indirme örneği aşağıdaki gibidir:


   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")

Yöntemler

child_run

Adım çalıştırması için alt çalıştırma. Bu yöntem StepRun için uygulanmaz.
complete

Adım çalıştırması için tamamlandı. Bu yöntem StepRun için uygulanmaz.
fail

Adım çalıştırması için başarısız oldu. Bu yöntem StepRun için uygulanmaz.
get_details_with_logs

Çalıştırmanın durum ayrıntılarını günlük dosyası içeriğiyle döndür.
get_job_log

Adım çalıştırması için geçerli iş günlüğünün dökümünü alır.
get_output

Verilen ada sahip düğüm çıkışını alın.
get_output_data

Belirli bir çıkıştan çıkış verilerini alın.
get_outputs

Adım çıkışlarını alın.
get_status

hizmetten işlem hattı çalıştırmasının en son durumunu getirin.

Döndürülen yaygın değerler şunlardır: "Çalışıyor", "Bitti" ve "Başarısız".
get_stderr_log

Adım çalıştırması için geçerli stderr günlüğünün dökümünü alır.
get_stdout_log

Adım çalıştırması için geçerli stdout günlüğünün dökümünü alın.
wait_for_completion

Bu adım çalıştırmasının tamamlanmasını bekleyin.

Beklemeden sonra durumu döndürür.

child_run

Adım çalıştırması için alt çalıştırma. Bu yöntem StepRun için uygulanmaz.

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

Parametreler

Name Description
name
str

Alt öğe için isteğe bağlı ad

varsayılan değer: None
run_id
str

Alt öğe için isteğe bağlı run_id, aksi takdirde varsayılan değeri kullanır

varsayılan değer: None
outputs
str

Alt öğe için izlenen isteğe bağlı çıkış dizini

varsayılan değer: None

Döndürülenler

Tür Description
Run

Alt çalıştırma

Özel durumlar

Tür Description
NotImplementedError

complete

Adım çalıştırması için tamamlandı. Bu yöntem StepRun için uygulanmaz.

complete()

Özel durumlar

Tür Description
NotImplementedError

fail

Adım çalıştırması için başarısız oldu. Bu yöntem StepRun için uygulanmaz.

fail()

Özel durumlar

Tür Description
NotImplementedError

get_details_with_logs

Çalıştırmanın durum ayrıntılarını günlük dosyası içeriğiyle döndür.

get_details_with_logs()

Döndürülenler

Tür Description
dict

Günlük dosyası içeriğiyle çalıştırmanın durumunu döndürür

Özel durumlar

Tür Description
NotImplementedError

get_job_log

Adım çalıştırması için geçerli iş günlüğünün dökümünü alır.

get_job_log()

Döndürülenler

Tür Description
str

Günlük dizesi.

Özel durumlar

Tür Description
NotImplementedError

get_output

Verilen ada sahip düğüm çıkışını alın.

get_output(name)

Parametreler

Name Description
name
Gerekli
str

Çıktının adı.

Döndürülenler

Tür Description
StepRunOutput

Verilen ada sahip StepRunOutput.

Özel durumlar

Tür Description
NotImplementedError

get_output_data

Belirli bir çıkıştan çıkış verilerini alın.

get_output_data(name)

Parametreler

Name Description
name
Gerekli
str

Çıktının adı.

Döndürülenler

Tür Description
PortDataReference

Adım çıkış verilerini temsil eden PortDataReference.

Özel durumlar

Tür Description
NotImplementedError

get_outputs

Adım çıkışlarını alın.

get_outputs()

Döndürülenler

Tür Description
dict

Anahtar olarak çıkış adıyla StepRunOutputs sözlüğü.

Özel durumlar

Tür Description
NotImplementedError

get_status

hizmetten işlem hattı çalıştırmasının en son durumunu getirin.

Döndürülen yaygın değerler şunlardır: "Çalışıyor", "Bitti" ve "Başarısız".

get_status()

Döndürülenler

Tür Description
str

Dize olarak en son durum

Özel durumlar

Tür Description
NotImplementedError

Açıklamalar

  • NotStarted - Bu geçici bir durumdur istemci tarafı Çalıştırma nesneleri bulut göndermeden önce içindedir

  • Kuyruğa alındı - İş kuyruğa alındı.

  • Çalışıyor - İş işlem hedefinde çalışmaya başladı.

  • Başarısız - Çalıştırma başarısız oldu. Genellikle bir çalıştırmadaki Error özelliği nedenine ilişkin ayrıntıları sağlar.

  • Bitti - Çalıştırma başarıyla tamamlandı.

  • İptal edildi - İptal isteğinin ardından çalıştırma artık başarıyla iptal edildi.


   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

Adım çalıştırması için geçerli stderr günlüğünün dökümünü alır.

get_stderr_log()

Döndürülenler

Tür Description
str

Günlük dizesi.

Özel durumlar

Tür Description
NotImplementedError

get_stdout_log

Adım çalıştırması için geçerli stdout günlüğünün dökümünü alın.

get_stdout_log()

Döndürülenler

Tür Description
str

Günlük dizesi.

Özel durumlar

Tür Description
NotImplementedError

wait_for_completion

Bu adım çalıştırmasının tamamlanmasını bekleyin.

Beklemeden sonra durumu döndürür.

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

Parametreler

Name Description
show_output
bool

show_output=True, sys.stdout üzerinde işlem hattı çalıştırma durumunu gösterir.

varsayılan değer: True
timeout_seconds
int

Zaman aşımına uğramadan önce bekliyecek saniye sayısı.

varsayılan değer: 9223372036854775807
raise_on_error
bool

Çalıştır başarısız durumdayken hata oluşturup oluşturmayacağını gösterir

varsayılan değer: True

Döndürülenler

Tür Description
str

Son durum.

Özel durumlar

Tür Description
NotImplementedError

Öznitelikler

pipeline_run_id

Bu adım çalıştırmasına karşılık gelen işlem hattı çalıştırmasının kimliğini döndürür.

Döndürülenler

Tür Description
str

PipelineRun kimliği.