MCPcopy
hub / github.com/celery/celery / test_promise

Method test_promise

t/unit/concurrency/test_prefork.py:306–311  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

304 assert f.fileno() in readable
305
306 def test_promise(self):
307 fun = Mock()
308 x = asynpool.promise(fun, (1,), {'foo': 1})
309 x()
310 assert x.ready
311 fun.assert_called_with(1, foo=1)
312
313 def test_Worker(self):
314 w = asynpool.Worker(Mock(), Mock())

Callers

nothing calls this directly

Calls 1

xFunction · 0.85

Tested by

no test coverage detected