MCPcopy
hub / github.com/celery/celery / _iter_schedule_requests

Function _iter_schedule_requests

celery/worker/control.py:412–424  ·  view source on GitHub ↗
(timer)

Source from the content-addressed store, hash-verified

410
411
412def _iter_schedule_requests(timer):
413 for waiting in timer.schedule.queue:
414 try:
415 arg0 = waiting.entry.args[0]
416 except (IndexError, TypeError):
417 continue
418 else:
419 if isinstance(arg0, Request):
420 yield {
421 'eta': arg0.eta.isoformat() if arg0.eta else None,
422 'priority': waiting.priority,
423 'request': arg0.info(),
424 }
425
426
427@inspect_command(alias='dump_reserved')

Callers 1

scheduledFunction · 0.85

Calls 1

infoMethod · 0.45

Tested by

no test coverage detected