Skip to content

Commit 4a583cf

Browse files
committed
fix issue with self.deliveryclerk.get_update_subjobs_in_database(self)
1 parent 06fc804 commit 4a583cf

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

simprod/simjob/simjob.py

+6-4
Original file line numberDiff line numberDiff line change
@@ -1329,8 +1329,8 @@ def status(self):
13291329
return "new"
13301330

13311331
if not self.last_status == "completed":
1332-
1333-
table_from_clerk, db_clerk = self.deliveryclerk.get_update_subjobs_in_database(self)
1332+
1333+
from_clerk = self.deliveryclerk.get_update_subjobs_in_database(self)
13341334

13351335
status_list = []
13361336

@@ -1339,7 +1339,8 @@ def status(self):
13391339
sj_doc = self.jobtable.get(doc_id=n)
13401340
sj = self.subjobs[n]
13411341

1342-
if table_from_clerk is not None:
1342+
if from_clerk is not None:
1343+
table_from_clerk, db_clerk = from_clerk
13431344
sj_doc_from_clerk = table_from_clerk.get(Query().subjobnumber == n)
13441345
else:
13451346
sj_doc_from_clerk = None
@@ -1373,6 +1374,8 @@ def status(self):
13731374
status, sj_doc_from_clerk["status"], sj.output
13741375
)
13751376
status = sj_doc_from_clerk["status"]
1377+
1378+
db_clerk.close()
13761379

13771380
if sj_doc["jobid"] != jobid or sj_doc["status"] != status:
13781381
sj_doc["jobid"] = jobid
@@ -1383,7 +1386,6 @@ def status(self):
13831386
# if status in ["completed", "failed"]:
13841387
# self.subjobs[n] = None
13851388

1386-
db_clerk.close()
13871389

13881390
status_list.append(status)
13891391

0 commit comments

Comments
 (0)