Add +CoffeaCasaWorkerType = dask

CoffeaTeam · Apr 19, 2024 · 7f1cfb0 · 7f1cfb0
1 parent 4f1392b
commit 7f1cfb0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/coffea_casa/coffea_casa.py b/coffea_casa/coffea_casa.py
@@ -205,6 +205,7 @@ def _modify_job_kwargs(cls,
             {"should_transfer_files": "YES"},
             {"Stream_Output": "False"},
             {"Stream_Error": "False"},
+            {"+CoffeaCasaWorkerType": "dask"},
             {"+DaskSchedulerAddress": external_ip_string},
             job_kwargs.get(
                 "job_extra_directives", dask.config.get(f"jobqueue.{cls.config_name}.job_extra_directives")