Aracılığıyla paylaş


StepRun Sınıf

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

experiment
Experiment
Gerekli

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

step_run_id
str
Gerekli

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

pipeline_run_id
str
Gerekli

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

node_id
str
Gerekli

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

_service_endpoint
str
varsayılan değer: None

Bağlanacak uç nokta.

_is_reused
bool
varsayılan değer: False

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

_current_node_id
str
varsayılan değer: None

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

_reused_run_id
str
varsayılan değer: None

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

_reused_node_id
str
varsayılan değer: None

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

_reused_pipeline_run_id
str
varsayılan değer: None

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

experiment
Experiment
Gerekli

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

step_run_id
str
Gerekli

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

pipeline_run_id
str
Gerekli

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

node_id
str
Gerekli

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

_service_endpoint
str
Gerekli

Bağlanacak uç nokta.

_is_reused
bool
Gerekli

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

_current_node_id
str
Gerekli

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

_reused_run_id
Gerekli
_reused_node_id
str
Gerekli
_reused_pipeline_run_id
str
Gerekli

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
str
varsayılan değer: None

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

run_id
str
varsayılan değer: None

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

outputs
str
varsayılan değer: None

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

Döndürülenler

Alt çalıştırma

Dönüş türü

Run

Özel durumlar

complete

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

complete()

Özel durumlar

fail

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

fail()

Özel durumlar

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

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

Dönüş türü

Özel durumlar

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

Günlük dizesi.

Dönüş türü

str

Özel durumlar

get_output

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

get_output(name)

Parametreler

name
str
Gerekli

Çıktının adı.

Döndürülenler

Verilen ada sahip StepRunOutput.

Dönüş türü

Özel durumlar

get_output_data

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

get_output_data(name)

Parametreler

name
str
Gerekli

Çıktının adı.

Döndürülenler

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

Dönüş türü

Özel durumlar

get_outputs

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

get_outputs()

Döndürülenler

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

Dönüş türü

Özel durumlar

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

Dize olarak en son durum

Dönüş türü

str

Özel durumlar

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

Günlük dizesi.

Dönüş türü

str

Özel durumlar

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

Günlük dizesi.

Dönüş türü

str

Özel durumlar

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

show_output
bool
varsayılan değer: True

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

timeout_seconds
int
varsayılan değer: 9223372036854775807

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

raise_on_error
bool
varsayılan değer: True

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

Döndürülenler

Son durum.

Dönüş türü

str

Özel durumlar

Ö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

PipelineRun kimliği.

Dönüş türü

str