Slurm args will be collected as a single string

tgen · Feb 7, 2019 · 9a89513 · 9a89513
1 parent ba4fc10
commit 9a89513
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/jetstream/backends/slurm.py b/jetstream/backends/slurm.py
@@ -159,7 +159,7 @@ async def spawn(self, task):
         task.state.update(
             label=f'Slurm({job.jid})',
             slurm_job_id=job.jid,
-            slurm_args=job.args
+            slurm_cmd=' '.join(shlex.quote(a) for a in job.args)
         )
         log.info(f'SlurmBackend submitted: {task}')
 
@@ -174,7 +174,7 @@ async def spawn(self, task):
                 job_info = {k: v for k, v in job.job_data.items() if
                             k in self.sacct_fields}
 
-                task.state['slurm'] = job_info
+                task.state['slurm_sacct'] = job_info
 
             if job.is_ok():
                 log.info(f'Complete: {task}')