diff --git a/coffea_casa/coffea_casa.py b/coffea_casa/coffea_casa.py index 6db3dd79..051f1154 100644 --- 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")