add: tags to prioritize our weekly schedules

opensource-observer · Sep 18, 2024 · ecbd000 · ecbd000
1 parent 9b244a4
commit ecbd000
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/warehouse/oso_dagster/schedules.py b/warehouse/oso_dagster/schedules.py
@@ -48,6 +48,9 @@ def execution_fn(
                 RunRequest(
                     run_key=f"{asset_path}_{partition_key}",
                     partition_key=partition_key,
+                    tags={
+                        "dagster/priority": "-1",
+                    },
                 )
                 for partition_key in factory_job.partitions_def.get_partition_keys()
                 if partition_key not in materialized_partitions
@@ -80,10 +83,16 @@ def execution_fn(
     ScheduleDefinition(
         job=materialize_all_assets,
         cron_schedule="0 0 * * 0",
+        tags={
+            "dagster/priority": "-1",
+        },
     ),
     # Run only source data every day (exclude sunday as it's already in the schedule above)
     ScheduleDefinition(
         job=materialize_source_assets,
         cron_schedule="0 0 * * 1-6",
+        tags={
+            "dagster/priority": "-1",
+        },
     ),
 ]