MCPcopy
hub / github.com/celery/celery / reserve

Method reserve

celery/beat.py:389–391  ·  view source on GitHub ↗
(self, entry)

Source from the content-addressed store, hash-verified

387 )
388
389 def reserve(self, entry):
390 new_entry = self.schedule[entry.name] = next(entry)
391 return new_entry
392
393 def apply_async(self, entry, producer=None, advance=True, **kwargs):
394 # Update time-stamps and run counts before we actually execute,

Callers 2

tickMethod · 0.95
apply_asyncMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected