Skip to content

Commit fb190ab

Browse files
committed
add some prints
1 parent a886761 commit fb190ab

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

src/sequence_processing_pipeline/Job.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -261,9 +261,11 @@ def _query_slurm(self, job_ids):
261261
# query_slurm encapsulates the handling of squeue.
262262
count = 0
263263
while True:
264+
print ('------> _query_slurm')
264265
result = self._system_call("squeue -t all -j "
265266
f"{','.join(job_ids)} "
266267
"-o '%i,%T'")
268+
print (result)
267269

268270
if result['return_code'] == 0:
269271
# there was no issue w/squeue, break this loop and
@@ -362,6 +364,7 @@ def submit_job(self, script_path, job_parameters=None,
362364
cmd = f'cd {exec_from};' + cmd
363365

364366
logging.debug("job scheduler call: %s" % cmd)
367+
print ('===>', cmd)
365368

366369
if self.force_job_fail:
367370
raise JobFailedError("This job died.")

tests/bin/sbatch

Lines changed: 0 additions & 2 deletions
This file was deleted.

tests/test_Job.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ def my_callback(jid=None, status=None):
5050
obs = job._system_call('ls ' + join(package_root, 'tests', 'bin'),
5151
callback=my_callback)
5252

53-
exp = ['bcl-convert\nbcl2fastq\nfake_squeue.py\nfastqc\nsbatch\n']
53+
exp = ['bcl-convert\nbcl2fastq\nfake_squeue.py\nfastqc\n']
5454

5555
self.assertIn(obs['stdout'], exp)
5656
self.assertEqual(obs['stderr'], '')

0 commit comments

Comments
 (0)