o wvXj4@sdZddlmZmZddlZddlmZddlmZm Z ddl m Z m Z m Z dZeZGdd d eZd d Zed kr?edSdS) aThe :program:`celery events` command. .. program:: celery events .. seealso:: See :ref:`preload-options` and :ref:`daemon-options`. .. cmdoption:: -d, --dump Dump events to stdout. .. cmdoption:: -c, --camera Take snapshots of events using this camera. .. cmdoption:: --detach Camera: Detach and run in the background as a daemon. .. cmdoption:: -F, --freq, --frequency Camera: Shutter frequency. Default is every 1.0 seconds. .. cmdoption:: -r, --maxrate Camera: Optional shutter rate limit (e.g., 10/m). .. cmdoption:: -l, --loglevel Logging level, choose between `DEBUG`, `INFO`, `WARNING`, `ERROR`, `CRITICAL`, or `FATAL`. Default is INFO. .. cmdoption:: -f, --logfile Path to log file. If no logfile is specified, `stderr` is used. .. cmdoption:: --pidfile Optional file used to store the process pid. The program won't start if this file already exists and the pid is still alive. .. cmdoption:: --uid User id, or user name of the user to run as after detaching. .. cmdoption:: --gid Group id, or group name of the main group to change to after detaching. .. cmdoption:: --umask Effective umask (in octal) of the process after detaching. Inherits the umask of the parent process by default. .. cmdoption:: --workdir Optional directory to change to after detaching. .. cmdoption:: --executable Executable to use for the detached process. )absolute_importunicode_literalsN)partial)Commanddaemon_options)detachedset_process_titlestrargv)eventsc@s\eZdZdZeZdZ    dddZd d Zd d Z   dd dZ dddZ ddZ dS)r a4Event-stream utilities. Notes: .. code-block:: console # - Start graphical monitor (requires curses) $ celery events --app=proj $ celery events -d --app=proj # - Dump events to screen. $ celery events -b amqp:// # - Run snapshot camera. $ celery events -c [options] Examples: .. code-block:: console $ celery events $ celery events -d $ celery events -c mod.attr -F 1.0 --detach --maxrate=100/m -l info FN?INFO celery eventsc Ks>||_|r |S|r|j||||||| | | | | d S|S)N) freqmaxrateloglevellogfilepidfileuidgidumaskworkdirdetach) prog_name run_evdump run_evcam run_evtop)selfdumpcamera frequencyrrrrrrrrrrkwargsr!N/var/www/html/myproject/venv/lib/python3.10/site-packages/celery/bin/events.pyrunjs z events.runcC"ddlm}|d||jdS)Nr)evdumprapp)celery.events.dumperr%set_process_statusr')rr%r!r!r"r{   zevents.run_evdumpcCr$)Nr)evtoptopr&)celery.events.cursesmonr+r)r')rr+r!r!r"rr*zevents.run_evtopc Ks~ddlm} |d|j| d<t| |f||d| } |rsB ]