Skip to content

Commit 9c5fd85

Browse files
author
Alexey Tsitkin
committed
fix signal handler bug
1 parent be1f73c commit 9c5fd85

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

eb_sqs/worker/service.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,8 +35,12 @@ def __init__(self):
3535

3636
def process_queues(self, queue_names):
3737
# type: (list) -> None
38-
signal.signal(signal.SIGTERM, self._exit_called)
39-
signal.signal(signal.SIGKILL, self._exit_called)
38+
def termination_handler(signum, frame):
39+
logger.info('[django-eb-sqs] Termination signal called: {}'.format(signum))
40+
self._exit_called()
41+
42+
signal.signal(signal.SIGTERM, termination_handler)
43+
signal.signal(signal.SIGKILL, termination_handler)
4044

4145
self.write_healthcheck_file()
4246
self._last_healthcheck_time = timezone.now()

0 commit comments

Comments
 (0)