MCPcopy
hub / github.com/celery/celery / subscribe

Method subscribe

t/unit/backends/test_redis.py:77–78  ·  view source on GitHub ↗
(self, *args)

Source from the content-addressed store, hash-verified

75 self._subscribed_to = set()
76
77 def subscribe(self, *args):
78 self._subscribed_to.update(args)
79
80 def unsubscribe(self, *args):
81 self._subscribed_to.difference_update(args)

Callers 2

_reconnect_pubsubMethod · 0.80
_consume_fromMethod · 0.80

Calls 1

updateMethod · 0.45

Tested by

no test coverage detected