Pulp

On Pulp 3, I get the following traceback when I start pulp resource manager before I start the workers.

[2017-05-25 19:45:15,022: CRITICAL/MainProcess] Unrecoverable error: TypeError("'NoneType' object is not callable",)
Traceback (most recent call last):
  File "/usr/lib/python3.5/site-packages/celery-4.0.2-py3.5.egg/celery/worker/worker.py", line 203, in start
    self.blueprint.start(self)
  File "/usr/lib/python3.5/site-packages/celery-4.0.2-py3.5.egg/celery/bootsteps.py", line 119, in start
    step.start(parent)
  File "/usr/lib/python3.5/site-packages/celery-4.0.2-py3.5.egg/celery/bootsteps.py", line 370, in start
    return self.obj.start()
  File "/usr/lib/python3.5/site-packages/celery-4.0.2-py3.5.egg/celery/worker/consumer/consumer.py", line 318, in start
    blueprint.start(self)
  File "/usr/lib/python3.5/site-packages/celery-4.0.2-py3.5.egg/celery/bootsteps.py", line 119, in start
    step.start(parent)
  File "/usr/lib/python3.5/site-packages/celery-4.0.2-py3.5.egg/celery/worker/consumer/consumer.py", line 594, in start
    c.loop(*c.loop_args())
  File "/usr/lib/python3.5/site-packages/celery-4.0.2-py3.5.egg/celery/worker/loops.py", line 47, in asynloop
    consumer.consume()
  File "/usr/lib/python3.5/site-packages/kombu-4.0.2-py3.5.egg/kombu/messaging.py", line 476, in consume
    self._basic_consume(T, no_ack=no_ack, nowait=False)
  File "/usr/lib/python3.5/site-packages/kombu-4.0.2-py3.5.egg/kombu/messaging.py", line 597, in _basic_consume
    no_ack=no_ack, nowait=nowait)
  File "/usr/lib/python3.5/site-packages/kombu-4.0.2-py3.5.egg/kombu/entity.py", line 737, in consume
    arguments=self.consumer_arguments)
  File "/usr/lib/python3.5/site-packages/amqp-2.1.4-py3.5.egg/amqp/channel.py", line 1578, in basic_consume
    wait=None if nowait else spec.Basic.ConsumeOk,
  File "/usr/lib/python3.5/site-packages/amqp-2.1.4-py3.5.egg/amqp/abstract_channel.py", line 73, in send_method
    return self.wait(wait, returns_tuple=returns_tuple)
  File "/usr/lib/python3.5/site-packages/amqp-2.1.4-py3.5.egg/amqp/abstract_channel.py", line 93, in wait
    self.connection.drain_events(timeout=timeout)
  File "/usr/lib/python3.5/site-packages/amqp-2.1.4-py3.5.egg/amqp/connection.py", line 464, in drain_events
    return self.blocking_read(timeout)
  File "/usr/lib/python3.5/site-packages/amqp-2.1.4-py3.5.egg/amqp/connection.py", line 469, in blocking_read
    return self.on_inbound_frame(frame)
  File "/usr/lib/python3.5/site-packages/amqp-2.1.4-py3.5.egg/amqp/method_framing.py", line 88, in on_frame
    callback(channel, msg.frame_method, msg.frame_args, msg)
  File "/usr/lib/python3.5/site-packages/amqp-2.1.4-py3.5.egg/amqp/connection.py", line 473, in on_inbound_method
    method_sig, payload, content,
  File "/usr/lib/python3.5/site-packages/amqp-2.1.4-py3.5.egg/amqp/abstract_channel.py", line 142, in dispatch_method
    listener(*args)
  File "/usr/lib/python3.5/site-packages/amqp-2.1.4-py3.5.egg/amqp/channel.py", line 1613, in _on_basic_deliver
    fun(msg)
  File "/usr/lib/python3.5/site-packages/kombu-4.0.2-py3.5.egg/kombu/messaging.py", line 623, in _receive_callback
    return on_m(message) if on_m else self.receive(decoded, message)
  File "/usr/lib/python3.5/site-packages/celery-4.0.2-py3.5.egg/celery/worker/consumer/consumer.py", line 568, in on_task_received
    callbacks,
  File "/usr/lib/python3.5/site-packages/celery-4.0.2-py3.5.egg/celery/worker/strategy.py", line 145, in task_message_handler
    handle(req)
  File "/usr/lib/python3.5/site-packages/celery-4.0.2-py3.5.egg/celery/worker/worker.py", line 221, in _process_task_sem
    return self._quick_acquire(self._process_task, req)
  File "/usr/lib/python3.5/site-packages/kombu-4.0.2-py3.5.egg/kombu/async/semaphore.py", line 62, in acquire
    callback(*partial_args, **partial_kwargs)
  File "/usr/lib/python3.5/site-packages/celery-4.0.2-py3.5.egg/celery/worker/worker.py", line 226, in _process_task
    req.execute_using_pool(self.pool)
  File "/usr/lib/python3.5/site-packages/celery-4.0.2-py3.5.egg/celery/worker/request.py", line 531, in execute_using_pool
    correlation_id=task_id,
  File "/usr/lib/python3.5/site-packages/celery-4.0.2-py3.5.egg/celery/concurrency/base.py", line 155, in apply_async
    **options)
  File "/usr/lib/python3.5/site-packages/billiard-3.5.0.2-py3.5.egg/billiard/pool.py", line 1487, in apply_async
    self._quick_put((TASK, (result._job, None, func, args, kwds)))
TypeError: 'NoneType' object is not callable