Skip to content

Commit

Permalink
interrupt last_line
Browse files Browse the repository at this point in the history
  • Loading branch information
joknarf committed Jul 8, 2024
1 parent c9683a6 commit 6436d7a
Showing 1 changed file with 4 additions and 13 deletions.
17 changes: 4 additions & 13 deletions ssh_para/ssh_para.py
Original file line number Diff line number Diff line change
Expand Up @@ -376,25 +376,16 @@ def interrupt(self, jstatus):
while True:
try:
jstatus = printq.get(block=False)
if jstatus.fdlog:
jstatus.log = last_line(jstatus.fdlog)
jstatus.fdlog.close()
if not jstatus.fdlog:
jstatus.fdlog = open(jstatus.logfile, "rb")
jstatus.log = last_line(jstatus.fdlog)
jstatus.fdlog.close()
if jstatus.exit in [-2, 255]:
jstatus.status = "KILLED"
jstatus.exit = 256
self.job_status.append(jstatus)
except queue.Empty:
break


# for jstatus in self.th_status:
# if jstatus.status != "IDLE" and jstatus.exit == None:
# if jstatus.fdlog:
# jstatus.fdlog.close()
# jstatus.status="KILLED"
# jstatus.exit = 256
# self.nbfailed += 1
# self.job_status.append(jstatus)
self.abort_jobs()
try:
curses.endwin()
Expand Down

0 comments on commit 6436d7a

Please sign in to comment.