def sigterm_handler(signum, frame): logging.warning('Received {}, will terminate soon after finishing current job.'.format(signal.Signals(signum).name)) task_queue.interrupted = True