MCPcopy
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

test_migrateMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected