MCPcopy
hub / github.com/celery/celery / test_message

Method test_message

t/unit/worker/test_strategy.py:48–55  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

46 assert proto1_to_proto2(self.message, self.body)
47
48 def test_message(self):
49 body, headers, decoded, utc = proto1_to_proto2(self.message, self.body)
50 assert body == ((1,), {'foo': 'baz'}, {
51 'callbacks': None, 'errbacks': None, 'chord': None, 'chain': None,
52 })
53 assert headers == dict(self.body, group='123')
54 assert decoded
55 assert not utc
56
57
58class test_default_strategy_proto2:

Callers

nothing calls this directly

Calls 1

proto1_to_proto2Function · 0.90

Tested by

no test coverage detected