Use constants from signal

This commit is contained in:
Nicola Soranzo
2019-08-27 17:37:45 +01:00
parent 2014b1deee
commit c8bebbe68b
2 changed files with 6 additions and 4 deletions
+4 -3
View File
@@ -5,6 +5,7 @@ import datetime
import errno
import logging
import os
import signal
import subprocess
import tempfile
import threading
@@ -165,7 +166,7 @@ class LocalJobRunner(BaseJobRunner):
if not self._check_pid(pid):
log.warning("stop_job(): %s: PID %d was already dead or can't be signaled" % (job.id, pid))
return
for sig in [15, 9]:
for sig in [signal.SIGTERM, signal.SIGKILL]:
try:
os.killpg(pid, sig)
except OSError as e:
@@ -220,10 +221,10 @@ class LocalJobRunner(BaseJobRunner):
return False
def _terminate(self, proc):
os.killpg(proc.pid, 15)
os.killpg(proc.pid, signal.SIGTERM)
sleep(1)
if proc.poll() is None:
os.killpg(proc.pid, 9)
os.killpg(proc.pid, signal.SIGKILL)
return proc.wait() # reap
def _handle_container(self, job_wrapper, proc):
+2 -1
View File
@@ -1,4 +1,5 @@
import os
import signal
import subprocess
from platform import system
from time import sleep
@@ -55,7 +56,7 @@ def __kill_posix(pid):
return False
if __check_pid():
for sig in [15, 9]:
for sig in [signal.SIGTERM, signal.SIGKILL]:
try:
os.killpg(pid, sig)
except OSError: