Fix runner param validation in the DRMAA runner

This commit is contained in:
Nate Coraor
2019-04-09 15:41:20 -04:00
parent b8285b6e43
commit d4aa845ce7
+1 -1
View File
@@ -44,7 +44,7 @@ class DRMAAJobRunner(AsynchronousJobRunner):
'drmaa_library_path': dict(map=str, default=os.environ.get('DRMAA_LIBRARY_PATH', None))}
for retry_exception in RETRY_EXCEPTIONS_LOWER:
runner_param_specs[retry_exception + '_state'] = dict(map=str, valid=lambda x: x in (model.Job.states.OK, model.Job.states.ERROR), default=model.Job.states.OK)
runner_param_specs[retry_exception + '_retries'] = dict(map=int, valid=lambda x: int >= 0, default=0)
runner_param_specs[retry_exception + '_retries'] = dict(map=int, valid=lambda x: int(x) >= 0, default=0)
if 'runner_param_specs' not in kwargs:
kwargs['runner_param_specs'] = dict()