MCPcopy
hub / github.com/celery/celery / wait

Method wait

celery/concurrency/thread.py:26–27  ·  view source on GitHub ↗
(self, timeout: float | None = None)

Source from the content-addressed store, hash-verified

24 self.get = self.f.result
25
26 def wait(self, timeout: float | None = None) -> None:
27 wait([self.f], timeout)
28
29
30class TaskPool(BasePool):

Callers 10

joinMethod · 0.45
stopMethod · 0.45
ensure_startedMethod · 0.45
stopMethod · 0.45
_next_entryMethod · 0.45
stopMethod · 0.45
_waitexecMethod · 0.45
on_stopMethod · 0.45
_entry_exitMethod · 0.45
terminate_jobMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected