This commit is contained in:
Steve Pulec 2019-11-21 17:53:58 -05:00
commit 72da9e96c2
13 changed files with 28 additions and 26 deletions

View file

@ -302,7 +302,9 @@ class Job(threading.Thread, BaseModel):
self.job_id = str(uuid.uuid4())
self.job_definition = job_def
self.job_queue = job_queue
self.job_state = "SUBMITTED" # One of SUBMITTED | PENDING | RUNNABLE | STARTING | RUNNING | SUCCEEDED | FAILED
self.job_state = (
"SUBMITTED"
) # One of SUBMITTED | PENDING | RUNNABLE | STARTING | RUNNING | SUCCEEDED | FAILED
self.job_queue.jobs.append(self)
self.job_started_at = datetime.datetime(1970, 1, 1)
self.job_stopped_at = datetime.datetime(1970, 1, 1)