fix(ceda-global): Update concurrency options

openclimatefix · Sep 12, 2024 · 06c5220 · 06c5220
1 parent c638b10
commit 06c5220
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/local_archives/nwp/ceda/ceda_global.py b/local_archives/nwp/ceda/ceda_global.py
@@ -31,6 +31,7 @@
         tags={
             "dagster/max_runtime": str(60 * 60 * 10), # Should take 6 ish hours
             "dagster/priority": "1",
+            "dagster/concurrency_key": "ceda-ftp-consumer",
         },
     partitions_def=dg.MonthlyPartitionsDefinition(
         start_date="2019-01-01",