MCPcopy
hub / github.com/celery/celery / _do_enter

Method _do_enter

celery/utils/timer2.py:116–121  ·  view source on GitHub ↗
(self, meth: str, *args: Any, **kwargs: Any)

Source from the content-addressed store, hash-verified

114 self.start()
115
116 def _do_enter(self, meth: str, *args: Any, **kwargs: Any) -> Entry:
117 self.ensure_started()
118 with self.mutex:
119 entry = getattr(self.schedule, meth)(*args, **kwargs)
120 self.not_empty.notify()
121 return entry
122
123 def enter(self, entry: Entry, eta: float, priority: Optional[int] = None) -> Entry:
124 return self._do_enter('enter_at', entry, eta, priority=priority)

Callers 5

enterMethod · 0.95
call_atMethod · 0.95
enter_afterMethod · 0.95
call_afterMethod · 0.95
call_repeatedlyMethod · 0.95

Calls 1

ensure_startedMethod · 0.95

Tested by

no test coverage detected