diff --git a/local_archives/nwp/ceda/ceda_global.py b/local_archives/nwp/ceda/ceda_global.py index a67a4cd..e5ae40a 100644 --- 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",