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)

매개 변수

반환

일정을 'Disabled'로 설정하고 실행할 수 없습니다.

disable(wait_for_provisioning=False, wait_timeout=3600)

매개 변수

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

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에 대한 폴링 사이의 시간(분)을 가져옵니다.

반환

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

반환

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

반환