diff --git a/coffea_casa/coffea_casa.py b/coffea_casa/coffea_casa.py index c7627603..b3c50d2b 100644 --- a/coffea_casa/coffea_casa.py +++ b/coffea_casa/coffea_casa.py @@ -207,8 +207,7 @@ def _modify_job_kwargs(cls, {"Stream_Error": "False"}, {"+CoffeaCasaWorkerType": "dask"}, {"+DaskSchedulerAddress": external_ip_string}, - {"+AccountingGroup": "cms.other.coffea.$ENV(HOSTNAME)"} -"} + {"+AccountingGroup": "cms.other.coffea.$ENV(HOSTNAME)"}, job_kwargs.get( "job_extra_directives", dask.config.get(f"jobqueue.{cls.config_name}.job_extra_directives") ),