Skip to content

Commit 62e3307

Browse files
committed
Add conditional waiting thread for job submission in NQSVJobExecutor
1 parent 2119efd commit 62e3307

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

src/psij/executors/batch/nqsv.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -131,15 +131,17 @@ def __init__(self, url: Optional[str] = None, config: Optional[NQSVExecutorConfi
131131
self.generator = TemplatedScriptGenerator(config, path)
132132
self.submit_frag = False
133133
self.cancel_frag = False
134+
self.use_wait_command = False
134135
self._wait_threads: List[_NQSJobWaitingThread] = []
135136

136137
# Override submit function.
137138
def submit(self, job: Job) -> None:
138139
"""Submit a job to the NQSV scheduler."""
139140
super().submit(job)
140-
thread = _NQSJobWaitingThread(job, self)
141-
thread.start()
142-
self._wait_threads.append(thread)
141+
if self.use_wait_command:
142+
thread = _NQSJobWaitingThread(job, self)
143+
thread.start()
144+
self._wait_threads.append(thread)
143145
return None
144146

145147
def generate_submit_script(self,

0 commit comments

Comments
 (0)