Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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_pubsub
Method · 0.80
_consume_from
Method · 0.80
Calls
1
update
Method · 0.45
Tested by
no test coverage detected