MCPcopy
hub / github.com/celery/celery / test_sync

Method test_sync

t/unit/worker/test_state.py:149–161  ·  view source on GitHub ↗
(self, p,
                  data1=['foo', 'bar', 'baz'], data2=['baz', 'ini', 'koz'])

Source from the content-addressed store, hash-verified

147 assert d['zrevoked'] is revoked
148
149 def test_sync(self, p,
150 data1=['foo', 'bar', 'baz'], data2=['baz', 'ini', 'koz']):
151 self.add_revoked(p, *data1)
152 for item in data2:
153 state.revoked.add(item)
154 p.sync()
155
156 assert p.db['zrevoked']
157 pickled = p.decompress(p.db['zrevoked'])
158 assert pickled
159 saved = pickle.loads(pickled)
160 for item in data2:
161 assert item in saved
162
163
164class SimpleReq:

Callers

nothing calls this directly

Calls 3

add_revokedMethod · 0.95
addMethod · 0.45
syncMethod · 0.45

Tested by

no test coverage detected