Differential D8684 Diff 40955 examples/docs_snippets/docs_snippets/concepts/partitions_schedules_sensors/schedules/preset_helper.py
Changeset View
Changeset View
Standalone View
Standalone View
examples/docs_snippets/docs_snippets/concepts/partitions_schedules_sensors/schedules/preset_helper.py
from dagster import daily_schedule | from dagster import daily_schedule | ||||
# start_preset_helper | # start_preset_helper | ||||
def daily_schedule_definition_from_pipeline_preset(pipeline, preset_name, start_date): | def daily_schedule_definition_from_pipeline_preset( | ||||
pipeline, preset_name, start_date | |||||
): | |||||
preset = pipeline.get_preset(preset_name) | preset = pipeline.get_preset(preset_name) | ||||
if not preset: | if not preset: | ||||
raise Exception( | raise Exception( | ||||
"Preset {preset_name} was not found " | "Preset {preset_name} was not found " | ||||
"on pipeline {pipeline_name}".format( | "on pipeline {pipeline_name}".format( | ||||
preset_name=preset_name, pipeline_name=pipeline.name | preset_name=preset_name, pipeline_name=pipeline.name | ||||
) | ) | ||||
) | ) | ||||
Show All 15 Lines |