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)