

def __init__(self, channel_layer, callback=None, message_retries=10, signal_handlers=True):
    self.channel_layer = channel_layer
    self.callback = callback
    self.message_retries = message_retries
    self.signal_handlers = signal_handlers
    self.termed = False
    self.in_job = False

dataset/ETHPy150Open andrewgodwin/channels/channels/worker.py Worker.__init__/original