o wvXj7-@sdZddlmZmZddlZddlmZddlmZm Z ddl m Z ddl m Z ddlmZdd lmZmZdd lmZd ZeZGd d d eZdddZedkrVedSdS)aProgram used to start a Celery worker instance. The :program:`celery worker` command (previously known as ``celeryd``) .. program:: celery worker .. seealso:: See :ref:`preload-options`. .. cmdoption:: -c, --concurrency Number of child processes processing the queue. The default is the number of CPUs available on your system. .. cmdoption:: -P, --pool Pool implementation: prefork (default), eventlet, gevent, threads or solo. .. cmdoption:: -n, --hostname Set custom hostname (e.g., 'w1@%%h'). Expands: %%h (hostname), %%n (name) and %%d, (domain). .. cmdoption:: -B, --beat Also run the `celery beat` periodic task scheduler. Please note that there must only be one instance of this service. .. note:: ``-B`` is meant to be used for development purposes. For production environment, you need to start :program:`celery beat` separately. .. cmdoption:: -Q, --queues List of queues to enable for this worker, separated by comma. By default all configured queues are enabled. Example: `-Q video,image` .. cmdoption:: -X, --exclude-queues List of queues to disable for this worker, separated by comma. By default all configured queues are enabled. Example: `-X video,image`. .. cmdoption:: -I, --include Comma separated list of additional modules to import. Example: -I foo.tasks,bar.tasks .. cmdoption:: -s, --schedule Path to the schedule database if running with the `-B` option. Defaults to `celerybeat-schedule`. The extension ".db" may be appended to the filename. .. cmdoption:: -O Apply optimization profile. Supported: default, fair .. cmdoption:: --prefetch-multiplier Set custom prefetch multiplier value for this worker instance. .. cmdoption:: --scheduler Scheduler class to use. Default is :class:`celery.beat.PersistentScheduler` .. cmdoption:: -S, --statedb Path to the state database. The extension '.db' may be appended to the filename. Default: {default} .. cmdoption:: -E, --task-events Send task-related events that can be captured by monitors like :program:`celery events`, `celerymon`, and others. .. cmdoption:: --without-gossip Don't subscribe to other workers events. .. cmdoption:: --without-mingle Don't synchronize with other workers at start-up. .. cmdoption:: --without-heartbeat Don't send event heartbeats. .. cmdoption:: --heartbeat-interval Interval in seconds at which to send worker heartbeat .. cmdoption:: --purge Purges all waiting tasks before the daemon is started. **WARNING**: This is unrecoverable, and the tasks will be deleted from the messaging server. .. cmdoption:: --time-limit Enables a hard time limit (in seconds int/float) for tasks. .. cmdoption:: --soft-time-limit Enables a soft time limit (in seconds int/float) for tasks. .. cmdoption:: --max-tasks-per-child Maximum number of tasks a pool worker can execute before it's terminated and replaced by a new worker. .. cmdoption:: --max-memory-per-child Maximum amount of resident memory, in KiB, that may be consumed by a child process before it will be replaced by a new one. If a single task causes a child process to exceed this limit, the task will be completed and the child process will be replaced afterwards. Default: no limit. .. cmdoption:: --autoscale Enable autoscaling by providing max_concurrency, min_concurrency. Example:: --autoscale=10,3 (always keep 3 processes, but grow to 10 if necessary) .. cmdoption:: --detach Start worker as a background process. .. cmdoption:: -f, --logfile Path to log file. If no logfile is specified, `stderr` is used. .. cmdoption:: -l, --loglevel Logging level, choose between `DEBUG`, `INFO`, `WARNING`, `ERROR`, `CRITICAL`, or `FATAL`. .. 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 :manpage:`umask(1)` (in octal) of the process after detaching. Inherits the :manpage:`umask(1)` 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) concurrency)Commanddaemon_options)detached_celeryd)string_t)maybe_drop_privileges) LOG_LEVELSmlevel)default_nodename)workermainc@sZeZdZdZeZdZdZdZddhZ dddZ dd d Z  dd d Z d dZ ddZdS)r aZStart worker instance. Examples: .. code-block:: console $ celery worker --app=proj -l info $ celery worker -A proj -l info -Q hipri,lopri $ celery worker -A proj --concurrency=4 $ celery worker -A proj --concurrency=1000 -P eventlet $ celery worker --autoscale=10,0 TFz --no-execvz --force-execvNcsxfdd|D}|durtjdn|}|durtjddn|}j|||\}}|g||i|S)Ncsg|] }|jvr|qS) removed_flags).0xselfrN/var/www/html/myproject/venv/lib/python3.10/site-packages/celery/bin/worker.py sz(worker.run_from_argv..r)sysargv prepare_args parse_options maybe_detach)r prog_namercommandoptionsargsrrr run_from_argvs zworker.run_from_argvcsTsddgntfddDr(fddDt|jtddS)N-D--detachc3s|]}|vVqdSNr)rarg)rrr sz&worker.maybe_detach..csg|]}|vr|qSrr)rv)doptsrrrsz'worker.maybe_detach..r)anyrappexecute_from_commandline SystemExit)rrr(r)rr(rrs zworker.maybe_detachc Kst||dt|p|jjj}|jjr| dr|d| t |}|rHzt |}Wnt yG|d |dddtDYnw|jjd ||||||||| |d| } | | jS) N)uidgidbeatzR-B option does not work on Windows. Please run celery beat as a separate service.z,Unknown level {0!r}. Please use one of {1}.|css|] }t|tr|VqdSr$) isinstancer)rlrrrr&s   zworker.run..)hostnamepool_clsloglevellogfilepidfilestatedbr)r rget_implementationr*conf worker_pool IS_WINDOWSgetdie host_formatr r KeyErrorformatjoinr Worker node_formatstartexitcode) rr3r4r*r-r.r5r6r7r8kwargsr rrrruns6         z worker.runcCs dgdgfS)N-P--poolr)rrrrrwith_pool_options zworker.with_pool_optionc Cs|jj}|d}|dd|jddddd|jd d |jd |jd d dd |jddd|jdt|jd|d}|jdd|jtd|jdd|jd |jdddd|j d|jdt |j d|jdt |j d|jdd t|j d|jd!d"t|jd|d#}|jd$d%ddd|jd&d'gd |jd(d)gd |jd*d+gd |d,}|jd-ddd|jd.ddd|jd/ddd|jd0td1|d2t||d3}|jd4d5ddd|jd6d7d8|jd |d9|jjd:}|r|d;} || |dSdS)s&1      !