def __init__()

in pythonflow/pfmq/worker.py [0:0]


    def __init__(self, target, address, dumps=None, loads=None, start=False, timeout=10,
                 max_retries=None):
        self.target = target
        self.address = address
        self.dumps = dumps or pickle.dumps
        self.loads = loads or pickle.loads
        self.max_retries = max_retries
        self.timeout = timeout

        super(Worker, self).__init__(start)