Schedule pipelines to run periodically
* * * * *
Key | Description | Example |
---|---|---|
env | The value is always prod in pipeline runs. The value is dev when running blocks in notebook. | prod |
event | If the pipeline is triggered by event, the event variable contains the event payload. | {"key1": "value1"} |
execution_date | A datetime object that the pipeline is executed at. | 86400 |
execution_partition | An automatically formatted partition of the pipeline run using the execution date. | 10/20231225T122520 |
pipeline_run_id | The id of the pipeline run. | 10 |
trigger_name | The trigger name of the pipeline run. | test run 1 |
kwargs
).
Key | Description | Example |
---|---|---|
interval_start_datetime | The datetime when the pipeline run is scheduled for. | datetime.datetime(2023, 7, 23, 7, 0, 0, 0) |
interval_end_datetime | The datetime when the next pipeline run is scheduled for. | datetime.datetime(2023, 7, 24, 7, 0, 0, 0) |
interval_seconds | The number of seconds between the current pipeline run and the next pipeline run. | 86400 |
interval_start_datetime_previous | The datetime when the previous pipeline run was scheduled for. | datetime.datetime(2023, 7, 22, 7, 0, 0, 0) |