MCPcopy
hub / github.com/celery/celery / events

Function events

celery/bin/events.py:83–98  ·  view source on GitHub ↗

Event-stream utilities.

(ctx, dump, camera, detach, frequency, maxrate, loglevel, **kwargs)

Source from the content-addressed store, hash-verified

81@click.pass_context
82@handle_preload_options
83def events(ctx, dump, camera, detach, frequency, maxrate, loglevel, **kwargs):
84 """Event-stream utilities."""
85 app = ctx.obj.app
86 try:
87 if dump:
88 return _run_evdump(app)
89
90 if camera:
91 return _run_evcam(camera, app=app, freq=frequency, maxrate=maxrate,
92 loglevel=loglevel,
93 detach=detach,
94 **kwargs)
95
96 return _run_evtop(app)
97 except Exception as exc:
98 handle_remote_command_error('events', exc)

Callers

nothing calls this directly

Calls 4

_run_evdumpFunction · 0.85
_run_evcamFunction · 0.85
_run_evtopFunction · 0.85

Tested by

no test coverage detected