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)

参数

将计划设置为“活动”，并可供运行。

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 之间获取多长时间（以分钟为单位）。

返回

获取计划重复周期。

返回

获取计划的状态。

返回