Differential D8612 Diff 40742 python_modules/dagster/dagster_tests/scheduler_tests/test_scheduler_run.py
Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster_tests/scheduler_tests/test_scheduler_run.py
| Show First 20 Lines • Show All 320 Lines • ▼ Show 20 Lines | def two_step_pipeline(): | ||||
| end(start()) | end(start()) | ||||
| manual_partition = PartitionSetDefinition( | manual_partition = PartitionSetDefinition( | ||||
| name="manual_partition", | name="manual_partition", | ||||
| pipeline_name="two_step_pipeline", | pipeline_name="two_step_pipeline", | ||||
| # selects only second step | # selects only second step | ||||
| solid_selection=["end"], | solid_selection=["end"], | ||||
| partition_fn=lambda: ["one"], | partition_fn=lambda: [Partition("one")], | ||||
| # includes config for first step - test that it is ignored | # includes config for first step - test that it is ignored | ||||
| run_config_fn_for_partition=lambda _: {"solids": {"start": {"inputs": {"x": {"value": 4}}}}}, | run_config_fn_for_partition=lambda _: {"solids": {"start": {"inputs": {"x": {"value": 4}}}}}, | ||||
| ) | ) | ||||
| manual_partition_schedule = manual_partition.create_schedule_definition( | manual_partition_schedule = manual_partition.create_schedule_definition( | ||||
| "manual_partition_schedule", "0 0 * * *", lambda _x, _y: Partition("one") | "manual_partition_schedule", "0 0 * * *", lambda _x, _y: Partition("one") | ||||
| ) | ) | ||||
| ▲ Show 20 Lines • Show All 1,414 Lines • Show Last 20 Lines | |||||