def __init__()

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

• 11 lines of code
• 3 McCabe index (conditional complexity)

    def __init__(self, requests, address, dumps=None, loads=None, start=True, timeout=10,
                 max_retries=3, max_results=1024):
        self.requests = requests
        self.address = address
        self.dumps = dumps or pickle.dumps
        self.loads = loads or pickle.loads
        self.max_results = max_results
        self.results = queue.Queue(self.max_results)
        self.timeout = timeout
        self.max_retries = max_retries

        super(Task, self).__init__(start)