diff --git a/nipype/pipeline/plugins/sge.py b/nipype/pipeline/plugins/sge.py index f27ffc4b7a..810794b811 100644 --- a/nipype/pipeline/plugins/sge.py +++ b/nipype/pipeline/plugins/sge.py @@ -47,12 +47,12 @@ def __init__(self, job_num, job_queue_state, job_time, job_queue_name, job_slots self._job_info_creation_time = time.time( ) # When this job was created (for comparing against initalization) self._job_queue_name = job_queue_name # Where the job is running - self._job_slots = job_slots # How many slots are being used + self._job_slots = int(job_slots) # How many slots are being used self._qsub_command_line = qsub_command_line def __repr__(self): return '{:<8d}{:12}{:<3d}{:20}{:8}{}'.format( - self._job_num, self._queue_state, self._job_slots, + self._job_num, self._job_queue_state, self._job_slots, time.strftime("%Y-%m-%dT%H:%M:%S", time.gmtime(self._job_time)), self._job_queue_name, self._qsub_command_line) @@ -91,7 +91,7 @@ def update_info(self, job_queue_state, job_time, job_queue_name, job_slots): self._job_queue_state = job_queue_state self._job_time = job_time self._job_queue_name = job_queue_name - self._job_slots = job_slots + self._job_slots = int(job_slots) def set_state(self, new_state): self._job_queue_state = new_state