Add AccountingGroup to imporve per-user job monitoring

CoffeaTeam · Aug 7, 2024 · e560699 · e560699
1 parent 3c708b6
commit e560699
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/coffea_casa/coffea_casa.py b/coffea_casa/coffea_casa.py
@@ -207,6 +207,8 @@ def _modify_job_kwargs(cls,
             {"Stream_Error": "False"},
             {"+CoffeaCasaWorkerType": "dask"},
             {"+DaskSchedulerAddress": external_ip_string},
+            {"+AccountingGroup": "cms.other.coffea.$ENV(HOSTNAME)"}
+"}
             job_kwargs.get(
                 "job_extra_directives", dask.config.get(f"jobqueue.{cls.config_name}.job_extra_directives")
             ),