Skip to content

Commit a741567

Browse files
authored
Merge pull request #129 from njzjz/submit
show message only when a job has been submitted successfully
2 parents 364eef9 + 2ab2e78 commit a741567

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

dpdispatcher/submission.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -547,11 +547,12 @@ def handle_unexpected_job_state(self):
547547
self.handle_unexpected_job_state()
548548

549549
if job_state == JobStatus.unsubmitted:
550-
dlog.info(f"job: {self.job_hash} unsubmitted; submit it")
550+
dlog.debug(f"job: {self.job_hash} unsubmitted; submit it")
551551
# if self.fail_count > 3:
552552
# raise RuntimeError("job:job {job} failed 3 times".format(job=self))
553553
self.submit_job()
554-
dlog.info("job: {job_hash} submit; job_id is {job_id}".format(job_hash=self.job_hash, job_id=self.job_id))
554+
if self.job_state != JobStatus.unsubmitted:
555+
dlog.info("job: {job_hash} submit; job_id is {job_id}".format(job_hash=self.job_hash, job_id=self.job_id))
555556
# self.get_job_state()
556557

557558
def get_hash(self):

0 commit comments

Comments
 (0)