celery.utils.dispatch

Base class for all signals

• receivers

  Internal attribute, holds a dictionary of

  `{receriverkey (id): weakref(receiver)}` mappings.

• connect(\args, **kwargs*)

  Connect receiver to sender for signal.

• disconnect(receiver=None, sender=None, weak=True, dispatch_uid=None)

  Disconnect receiver from sender for signal.

  If weak references are used, disconnect need not be called. The receiver will be removed from dispatch automatically.

• send_robust(sender, \*named*)

  Send signal from sender to all connected receivers catching errors.

  if any receiver raises an error (specifically any subclass of Exception), the error instance is returned as the result for that receiver.