Source code for ewoksjob.worker.process_utils
import os
import signal
from celery.concurrency import prefork
from billiard.common import reset_signals
[docs]
def process_initializer(*args):
os.environ["FORKED_BY_MULTIPROCESSING"] = "1"
prefork.process_initializer(*args)
reset_signals(full=True)
try:
signal.signal(signal.SIGINT, signal.SIG_IGN)
except AttributeError:
pass
process_destructor = prefork.process_destructor