Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/celery/celery
/ stop
Method
stop
celery/backends/redis.py:142–144 ·
view source on GitHub ↗
(self)
Source
from the content-addressed store, hash-verified
140
self.on_state_change(meta, None)
141
142
def
stop(self):
143
if
self._pubsub is not None:
144
self._pubsub.close()
145
146
def
drain_events(self, timeout=None):
147
if
self._pubsub:
Callers
nothing calls this directly
Calls
1
close
Method · 0.45
Tested by
no test coverage detected