Schedule 클래스

파이프라인에 대한 일정을 만듭니다.

시간 기반 일정에 대해 되풀이를 지정하거나 데이터 저장소, (선택 사항) polling_interval 및(선택 사항) data_path_parameter_name 지정하여 데이터 저장소 위치에서 수정/추가를 모니터링하는 일정을 만듭니다.

static create(workspace, name, pipeline_id, experiment_name, recurrence=None, description=None, pipeline_parameters=None, wait_for_provisioning=False, wait_timeout=3600, datastore=None, polling_interval=5, data_path_parameter_name=None, continue_on_step_failure=None, path_on_datastore=None, _workflow_provider=None, _service_endpoint=None)

매개 변수

반환

파이프라인 엔드포인트에 대한 일정을 만듭니다.

시간 기반 일정에 대해 되풀이를 지정하거나 데이터 저장소, (선택 사항) polling_interval 및(선택 사항) data_path_parameter_name 지정하여 데이터 저장소 위치에서 수정/추가를 모니터링하는 일정을 만듭니다.

static create_for_pipeline_endpoint(workspace, name, pipeline_endpoint_id, experiment_name, recurrence=None, description=None, pipeline_parameters=None, wait_for_provisioning=False, wait_timeout=3600, datastore=None, polling_interval=5, data_path_parameter_name=None, continue_on_step_failure=None, path_on_datastore=None, _workflow_provider=None, _service_endpoint=None)

매개 변수

반환

일정을 '사용 안 함'으로 설정하고 실행할 수 없습니다.

disable(wait_for_provisioning=False, wait_timeout=3600)

매개 변수

일정을 '활성'으로 설정하고 실행할 수 있습니다.

enable(wait_for_provisioning=False, wait_timeout=3600)

매개 변수

지정된 ID를 사용하여 일정을 가져옵니다.

static get(workspace, id, _workflow_provider=None, _service_endpoint=None)

매개 변수

반환

현재 작업 영역에서 모든 일정을 가져옵니다.

사용되지 않음: 이 메서드는 메서드를 위해 list 더 이상 사용되지 않습니다.

static get_all(workspace, active_only=True, pipeline_id=None, pipeline_endpoint_id=None, _workflow_provider=None, _service_endpoint=None)

매개 변수

반환

일정에 의해 제출된 마지막 파이프라인 실행을 가져옵니다. 실행이 제출되지 않은 경우 None을 반환합니다.

get_last_pipeline_run()

반환

일정에서 생성된 파이프라인 실행을 가져옵니다.

get_pipeline_runs()

반환

지정된 파이프라인 엔드포인트 ID에 대한 모든 일정을 가져옵니다.

static get_schedules_for_pipeline_endpoint_id(workspace, pipeline_endpoint_id, _workflow_provider=None, _service_endpoint=None)

매개 변수

반환

지정된 파이프라인 ID에 대한 모든 일정을 가져옵니다.

static get_schedules_for_pipeline_id(workspace, pipeline_id, _workflow_provider=None, _service_endpoint=None)

매개 변수

반환

현재 작업 영역에서 모든 일정을 가져옵니다.

static list(workspace, active_only=True, pipeline_id=None, pipeline_endpoint_id=None, _workflow_provider=None, _service_endpoint=None)

매개 변수

반환

YAML 파일을 로드하고 읽어 일정 매개 변수를 가져옵니다.

YAML 파일은 일정 매개 변수를 전달하여 일정을 만드는 한 가지 방법입니다.

static load_yaml(workspace, filename, _workflow_provider=None, _service_endpoint=None)

매개 변수

반환

설명

일정에 대해 두 가지 유형의 YAML이 지원됩니다. 첫 번째 읽기 및 트리거 파이프라인에 대 한 일정 만들기에 대 한 되풀이 정보를 로드 합니다. 두 번째 읽기 및 트리거 파이프라인에 대 한 일정 만들기에 대 한 데이터 저장소 정보를 로드 합니다.

다음과 같이 되풀이에 파이프라인을 제출하는 일정을 만드는 예제입니다.

   from azureml.pipeline.core import Schedule

   schedule_info = Schedule.load_yaml(workspace=workspace,
                                      filename='./yaml/test_schedule_with_recurrence.yaml')
   schedule = Schedule.create(workspace, name="TestSchedule", pipeline_id="pipeline_id",
                              experiment_name="helloworld", recurrence=schedule_info.get("recurrence"),
                              description=schedule_info.get("description"))

샘플 YAML 파일 test_schedule_with_recurrence.yaml:

   Schedule:
       description: "Test create with recurrence"
       recurrence:
           frequency: Week # Can be "Minute", "Hour", "Day", "Week", or "Month".
           interval: 1 # how often fires
           start_time: 2019-06-07T10:50:00
           time_zone: UTC
           hours:
           - 1
           minutes:
           - 0
           time_of_day: null
           week_days:
           - Friday
       pipeline_parameters: {'a':1}
       wait_for_provisioning: True
       wait_timeout: 3600
       datastore_name: ~
       polling_interval: ~
       data_path_parameter_name: ~
       continue_on_step_failure: None
       path_on_datastore: ~

데이터 저장소에 파이프라인을 제출할 일정을 만드는 예제는 다음과 같습니다.

   from azureml.pipeline.core import Schedule

   schedule_info = Schedule.load_yaml(workspace=workspace,
                                      filename='./yaml/test_schedule_with_datastore.yaml')
   schedule = Schedule.create(workspace, name="TestSchedule", pipeline_id="pipeline_id",
                              experiment_name="helloworld",datastore=schedule_info.get("datastore_name"),
                              polling_interval=schedule_info.get("polling_interval"),
                              data_path_parameter_name=schedule_info.get("data_path_parameter_name"),
                              continue_on_step_failure=schedule_info.get("continue_on_step_failure"),
                              path_on_datastore=schedule_info.get("path_on_datastore"))

일정을 업데이트합니다.

update(name=None, description=None, recurrence=None, pipeline_parameters=None, status=None, wait_for_provisioning=False, wait_timeout=3600, datastore=None, polling_interval=None, data_path_parameter_name=None, continue_on_step_failure=None, path_on_datastore=None)

매개 변수

설정의 값을 가져옵니다 continue_on_step_failure .

반환

변경된 Blob 경로로 설정할 데이터 경로 파이프라인 매개 변수의 이름을 가져옵니다.

반환

일정에 사용되는 데이터 저장소의 이름을 가져옵니다.

반환

일정에 대한 설명을 가져옵니다.

반환

일정의 ID를 가져옵니다.

반환

일정의 이름을 가져옵니다.

반환

일정이 모니터링하는 데이터 저장소의 경로를 가져옵니다.

반환

일정이 제출하는 파이프라인 엔드포인트의 ID를 가져옵니다.

반환

일정이 제출하는 파이프라인의 ID를 가져옵니다.

반환

수정/추가된 Blob에 대한 폴링 간격(분)을 가져옵니다.

반환

일정 되풀이를 가져옵니다.

반환

일정의 상태를 가져옵니다.

반환