We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ce2154a commit e7c8cb7Copy full SHA for e7c8cb7
nipype/pipeline/plugins/slurm.py
@@ -17,7 +17,7 @@
17
from ...interfaces.base import CommandLine
18
from .base import SGELikeBatchManagerBase, logger
19
20
-iflogger = logging.getLogger('nipype.interface')
+iflogger = logging.getLogger('nipype.workflow')
21
22
23
class SLURMPlugin(SGELikeBatchManagerBase):
@@ -73,6 +73,10 @@ def _is_pending(self, taskid):
73
if any(ss in str(e) for ss
74
in ['Socket timed out', 'not available at the moment']):
75
# do not raise error and allow recheck
76
+ logger.warning(
77
+ "SLURM timeout encountered while checking job status,
78
+ "treating job %d as pending", taskid
79
+ )
80
return True
81
if 'Invalid job id' not in str(e):
82
raise(e)
0 commit comments