Sync node schedulers with workflow scheduler

During _write_job_file for a workflow make sure that all of the node jobs have the scheduler and remote_id set the same as the parent workflow.
tethysplatform · Oct 4, 2017 · a5c5b7e · a5c5b7e
1 parent b439f17
commit a5c5b7e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/condorpy/workflow.py b/condorpy/workflow.py
@@ -208,6 +208,8 @@ def _write_job_file(self):
         dag_file.write(self.__str__())
         dag_file.close()
         for node in self._node_set:
+            node.job._scheduler = self._scheduler
+            node.job._remote_id = self._remote_id
             node.job._cwd = self._cwd
             node.job._write_job_file()