MCPcopy
hub / github.com/celery/celery / _wait_for_pending

Method _wait_for_pending

celery/backends/asynchronous.py:302–309  ·  view source on GitHub ↗
(self, result,
                          timeout=None, on_interval=None, on_message=None,
                          **kwargs)

Source from the content-addressed store, hash-verified

300 return result.maybe_throw(callback=callback, propagate=propagate)
301
302 def _wait_for_pending(self, result,
303 timeout=None, on_interval=None, on_message=None,
304 **kwargs):
305 return self.result_consumer._wait_for_pending(
306 result, timeout=timeout,
307 on_interval=on_interval, on_message=on_message,
308 **kwargs
309 )
310
311 @property
312 def is_async(self):

Callers 2

iter_nativeMethod · 0.95
wait_for_pendingMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected