PipelineRun Sınıf
bir çalıştırmayı Pipelinetemsil eder.
Bu sınıf, işlem hattı çalıştırması gönderildikten sonra çalıştırma ayrıntılarını yönetmek, denetlemek ve almak için kullanılabilir. İşlem hattı çalıştırması StepRun tarafından oluşturulan nesneleri almak için kullanınget_steps. Diğer kullanımlar arasında işlem hattı çalıştırmasıyla ilişkili nesneyi alma Graph , işlem hattı çalıştırmasının durumunu getirme ve çalıştırmanın tamamlanmasını bekleme sayılabilir.
İşlem hattı çalıştırması başlatın.
- Devralma
-
PipelineRun
Oluşturucu
PipelineRun(experiment, run_id, _service_endpoint=None, **kwags)
Parametreler
Name | Description |
---|---|
experiment
Gerekli
|
İşlem hattı çalıştırmasıyla ilişkili deneme nesnesi. |
run_id
Gerekli
|
İşlem hattı çalıştırmasının çalıştırma kimliği. |
_service_endpoint
|
Bağlanacak uç nokta. varsayılan değer: None
|
experiment
Gerekli
|
İşlem hattı çalıştırmasıyla ilişkili deneme nesnesi. |
run_id
Gerekli
|
İşlem hattı çalıştırmasının çalıştırma kimliği. |
_service_endpoint
Gerekli
|
Bağlanacak uç nokta. |
Açıklamalar
aracılığıyla submitbir gönderilirken pipelinerun Pipeline nesnesi döndürülür. Experimentyöntemi. İşlem Hattı oluşturma ve gönderme hakkında daha fazla bilgi için bkz. https://aka.ms/pl-first-pipeline.
Bir PipelineRun örneği de çalıştırmanın Experiment gönderildiği ve PipelineRun Kimliği ile aşağıdaki gibi oluşturulabilir:
from azureml.core import Experiment
from azureml.pipeline.core import PipelineRun
experiment = Experiment(workspace, "<experiment_name>")
pipeline_run = PipelineRun(experiment, "<pipeline_run_id>")
PipelineRun ile çalışırken şu komutu kullanın:
wait_for_completion çalıştırma durumunu izlemek ve isteğe bağlı olarak çalıştırma günlüklerinin akışını yapmak için.
get_status çalıştırma durumunu getirmek için.
cancel devam eden bir PipelineRun'ı iptal etmek için.
get_steps oluşturulan StepRuns'ı listelemek için. PipelineRun, İşlem Hattı'ndaki her adım için bir StepRun oluşturur.
Yöntemler
cancel |
Devam eden çalıştırmayı iptal edin. |
child_run |
İşlem hattı çalıştırması için bir alt çalıştırma oluşturun. Bu yöntem PipelineRun için uygulanmaz. |
complete |
İşlem hattı çalıştırmasını tamamlandı olarak işaretleyin. Bu yöntem PipelineRun için uygulanmaz. Bu yöntem işlem hatları için desteklenmez; tamamlanma/başarısız durumu Azure ML arka ucu tarafından yönetilir. |
fail |
İşlem hattı çalıştırmasını başarısız olarak işaretleyin. Bu yöntem PipelineRun için uygulanmaz. Bu yöntem işlem hatları için desteklenmez; tamamlanma/başarısız durumu Azure ML arka ucu tarafından yönetilir. |
find_step_run |
İşlem hattında ada göre bir adım çalıştırması bulun. |
get |
Çalıştırma kimliğine göre işlem hattı çalıştırması getirme. |
get_graph |
İşlem hattı çalıştırmasının grafiğini alın. |
get_pipeline_output |
Verilen işlem hattı çıkışı için PortDataReference değerini alın. |
get_pipeline_runs |
Yayımlanmış bir işlem hattından oluşturulan işlem hattı çalıştırmalarını getirin. |
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_steps |
Tamamlanan veya çalışmaya başlayan tüm işlem hattı adımları için adım çalıştırmalarını alın. |
get_tags |
Çalıştırma için etiket kümesini alın. |
publish_pipeline |
bir işlem hattı yayımlayın ve yeniden çalıştırılabilmesini sağlayın. İşlem hattı uç noktasını bu işlev tarafından döndürülen PublishedPipeline nesnesinden alabilirsiniz. İşlem hattı uç noktasıyla, REST çağrılarını kullanarak dış uygulamalardan işlem hattını çağırabilirsiniz. REST uç noktalarını çağırırken kimlik doğrulaması yapma hakkında bilgi için bkz https://aka.ms/pl-restep-auth. . İşlem hattı çalıştırmasıyla ilişkili özgün işlem hattı, yayımlanan işlem hattının temeli olarak kullanılır. |
save |
İşlem hattı YAML'sini bir dosyaya kaydedin. |
wait_for_completion |
Bu işlem hattı çalıştırmasının tamamlanmasını bekleyin. Beklemeden sonra durumu döndürür. |
cancel
Devam eden çalıştırmayı iptal edin.
cancel()
child_run
İşlem hattı çalıştırması için bir alt çalıştırma oluşturun. Bu yöntem PipelineRun için uygulanmaz.
child_run(name=None, run_id=None, outputs=None)
Parametreler
Name | Description |
---|---|
name
|
Çocuk için isteğe bağlı ad. varsayılan değer: None
|
run_id
|
Alt öğe için isteğe bağlı çalıştırma kimliği, aksi takdirde varsayılanı kullanır. varsayılan değer: None
|
outputs
|
Alt öğe için izlenen isteğe bağlı çıkış dizini. varsayılan değer: None
|
Döndürülenler
Tür | Description |
---|---|
Çocuk koşuyor. |
Özel durumlar
Tür | Description |
---|---|
complete
İşlem hattı çalıştırmasını tamamlandı olarak işaretleyin. Bu yöntem PipelineRun için uygulanmaz.
Bu yöntem işlem hatları için desteklenmez; tamamlanma/başarısız durumu Azure ML arka ucu tarafından yönetilir.
complete()
Özel durumlar
Tür | Description |
---|---|
fail
İşlem hattı çalıştırmasını başarısız olarak işaretleyin. Bu yöntem PipelineRun için uygulanmaz.
Bu yöntem işlem hatları için desteklenmez; tamamlanma/başarısız durumu Azure ML arka ucu tarafından yönetilir.
fail()
Özel durumlar
Tür | Description |
---|---|
find_step_run
İşlem hattında ada göre bir adım çalıştırması bulun.
find_step_run(name)
Parametreler
Name | Description |
---|---|
name
Gerekli
|
Bulunacak adımın adı. |
Döndürülenler
Tür | Description |
---|---|
StepRun Sağlanan ada sahip nesnelerin listesi. |
get
Çalıştırma kimliğine göre işlem hattı çalıştırması getirme.
static get(workspace, run_id, _service_endpoint=None)
Parametreler
Name | Description |
---|---|
workspace
Gerekli
|
İşlem hattıyla ilişkili çalışma alanı. |
run_id
Gerekli
|
İşlem hattı çalıştırmasının kimliği. |
_service_endpoint
|
Bağlanacak uç nokta. varsayılan değer: None
|
Döndürülenler
Tür | Description |
---|---|
PipelineRun nesnesi. |
get_graph
get_pipeline_output
Verilen işlem hattı çıkışı için PortDataReference değerini alın.
get_pipeline_output(pipeline_output_name)
Parametreler
Name | Description |
---|---|
pipeline_output_name
Gerekli
|
Alınacak işlem hattı çıkışının adı. |
Döndürülenler
Tür | Description |
---|---|
İşlem hattı çıkış verilerini temsil eden PortDataReference. |
get_pipeline_runs
Yayımlanmış bir işlem hattından oluşturulan işlem hattı çalıştırmalarını getirin.
static get_pipeline_runs(workspace, pipeline_id, _service_endpoint=None)
Parametreler
Name | Description |
---|---|
workspace
Gerekli
|
İşlem hattıyla ilişkili çalışma alanı. |
pipeline_id
Gerekli
|
Yayımlanan işlem hattının kimliği. |
_service_endpoint
|
Bağlanacak uç nokta. varsayılan değer: None
|
Döndürülenler
Tür | Description |
---|---|
Nesnelerin listesi PipelineRun . |
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 |
---|---|
Dize olarak en son durum. |
Açıklamalar
NotStarted - Bu geçici bir durumdur istemci tarafı Çalıştırma nesneleri bulut göndermeden önce içindedir
Ç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_steps
Tamamlanan veya çalışmaya başlayan tüm işlem hattı adımları için adım çalıştırmalarını alın.
get_steps()
Döndürülenler
Tür | Description |
---|---|
Nesnelerin listesi StepRun . |
get_tags
Çalıştırma için etiket kümesini alın.
get_tags()
Döndürülenler
Tür | Description |
---|---|
Çalıştırma için etiketlerin sözlüğü. |
publish_pipeline
bir işlem hattı yayımlayın ve yeniden çalıştırılabilmesini sağlayın.
İşlem hattı uç noktasını bu işlev tarafından döndürülen PublishedPipeline nesnesinden alabilirsiniz. İşlem hattı uç noktasıyla, REST çağrılarını kullanarak dış uygulamalardan işlem hattını çağırabilirsiniz. REST uç noktalarını çağırırken kimlik doğrulaması yapma hakkında bilgi için bkz https://aka.ms/pl-restep-auth. .
İşlem hattı çalıştırmasıyla ilişkili özgün işlem hattı, yayımlanan işlem hattının temeli olarak kullanılır.
publish_pipeline(name, description, version, continue_on_step_failure=None, **kwargs)
Parametreler
Name | Description |
---|---|
name
Gerekli
|
Yayımlanan işlem hattının adı. |
description
Gerekli
|
Yayımlanan işlem hattının açıklaması. |
version
Gerekli
|
Yayımlanan işlem hattının sürümü. |
continue_on_step_failure
|
Bir adım başarısız olursa PipelineRun'daki diğer adımların yürütülmesine devam edilip edilmeyeceği. Varsayılan değer False'tur. varsayılan değer: None
|
kwargs
Gerekli
|
Gelecekteki geliştirmeler için ayrılmış özel anahtar sözcük bağımsız değişkenleri |
Döndürülenler
Tür | Description |
---|---|
Yayımlanan işlem hattı oluşturuldu. |
save
İşlem hattı YAML'sini bir dosyaya kaydedin.
save(path=None)
Parametreler
Name | Description |
---|---|
path
|
YAML'nin kaydedilecek yol. Yol bir dizinse, işlem hattı YAML dosyası path>/pipeline.yml adresine <kaydedilir. Yol yoksa, geçerli dizin kullanılır. varsayılan değer: None
|
Döndürülenler
Tür | Description |
---|---|
wait_for_completion
Bu işlem hattı ç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
|
sys.stdout üzerinde işlem hattı çalıştırma durumunun gösterilip gösterilmeyeceğini gösterir. varsayılan değer: True
|
timeout_seconds
|
Zaman aşımına uğramadan önce bekliyecek saniye sayısı. varsayılan değer: 9223372036854775807
|
raise_on_error
|
Çalıştırma 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 |
---|---|
Son durum. |
Geri Bildirim
https://aka.ms/ContentUserFeedback.
Çok yakında: 2024 boyunca, içerik için geri bildirim mekanizması olarak GitHub Sorunları’nı kullanımdan kaldıracak ve yeni bir geri bildirim sistemiyle değiştireceğiz. Daha fazla bilgi için bkz.Gönderin ve geri bildirimi görüntüleyin