Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/celery/celery
/ publish
Method
publish
t/unit/events/test_events.py:18–21 ·
view source on GitHub ↗
(self, msg, *args, **kwargs)
Source
from the content-addressed store, hash-verified
16
self.sent = []
17
18
def
publish(self, msg, *args, **kwargs):
19
if
self.raise_on_publish:
20
raise
KeyError()
21
self.sent.append(msg)
22
23
def
close(self):
24
pass
Callers
2
before_task_publish_handler
Method · 0.45
test_migrate
Method · 0.45
Calls
no outgoing calls
Tested by
no test coverage detected