๓ P'—^c@@sฐdZddlmZddlZddlmZddlmZddlm Z ddl m Z dd d gZ d Z d „Zdefd „ƒYZd efd„ƒYZdS(sŸ celery.app.control ~~~~~~~~~~~~~~~~~~~ Client for worker remote control commands. Server implementation is in :mod:`celery.worker.control`. i(tabsolute_importN(tMailbox(tcached_property(tDuplicateNodenameWarning(t pluralizetInspecttControlt flatten_replyszReceived multiple replies from node {0}: {1}. Please make sure you give each node a unique nodename using the `-n` option.cC@sคitƒ}}xG|D]?}g|D]!}||kr$|j|ƒ^q$|j|ƒqW|r tjttjtt |ƒdƒdj t |ƒƒƒƒƒn|S(Ntnames, ( tsettaddtupdatetwarningstwarnRt W_DUPNODEtformatRtlentjointsorted(treplytnodestdupestitemR((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRs , 1cB@s์eZdZddddddd„Zd„Zd„Zd„Zd„Ze d„Z e d„Z e d„Z d „Z d „Zd „ZeZd „Zd „Zd„Ze d„Zdd„Zd„Zdd„Zdddd„ZRS(icC@sC|p |j|_||_||_||_||_||_dS(N(tappt destinationttimeouttcallbackt connectiontlimit(tselfRRRRRR((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyt__init__-s     cC@sL|s dSt|ƒ}|jrHt|jttfƒ rH|j|jƒS|S(N(RRt isinstancetlistttupletget(RRtby_node((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyt_prepare6s  cK@sU|j|jjj|d|d|jd|jd|jd|jd|jdt ƒƒS(Nt argumentsRRRRRR( R$Rtcontrolt broadcastRRRRRtTrue(Rtcommandtkwargs((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyt_request?s    cC@s |jdƒS(Ntreport(R+(R((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyR,JscC@s |jdƒS(Ntclock(R+(R((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyR-MscC@s|jdd|ƒS(Nt dump_activetsafe(R+(RR/((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pytactivePscC@s|jdd|ƒS(Nt dump_scheduleR/(R+(RR/((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyt scheduledSscC@s|jdd|ƒS(Nt dump_reservedR/(R+(RR/((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pytreservedVscC@s |jdƒS(Ntstats(R+(R((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyR5YscC@s |jdƒS(Nt dump_revoked(R+(R((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pytrevoked\scG@s|jdd|ƒS(Nt dump_taskst taskinfoitems(R+(RR9((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyt registered_scC@s |jdƒS(Ntping(R+(R((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyR;cscC@s |jdƒS(Nt active_queues(R+(R((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyR<fscC@s|jdd|ƒS(Nt query_tasktids(R+(RR>((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyR=iscC@s|jdd|ƒS(Nt dump_conft with_defaults(R+(RR@((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pytconflscC@s|jdd|d|ƒS(Nthellot from_nodeR7(R+(RRCR7((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRBoscC@s |jdƒS(Nt memsample(R+(R((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRDrsi cC@s|jdd|ƒS(Ntmemdumptsamples(R+(RRF((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyREustRequestiศcC@s|jdd|d|d|ƒS(Ntobjgraphtnumt max_depthttype(R+(RRKtnRJ((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRHxsN(t__name__t __module__tNoneRRR$R+R,R-tFalseR0R2R4R5R7R:tregistered_tasksR;R<R=RARBRDRERH(((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyR*s,                c B@seZeZdd„Zed„ƒZdd„ZeZddd„Z de dd„Z ddd„Z dd„Z dd ddd „Zd „Zddd „Zdd „Zdd„Zddd„Zddd„Zdd„Zddde ddddd„ZRS(cC@s.||_|jdddddgƒ|_dS(NtceleryRKtfanouttaccepttjson(RRtmailbox(RR((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRs cC@s|jjtddƒS(Ntreversescontrol.inspect(Rtsubclass_with_selfR(R((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pytinspectƒscC@s8|jj|ƒ }|jjj|ƒjƒSWdQXdS(sอDiscard all waiting tasks. This will ignore all tasks waiting for execution, and they will be deleted from the messaging server. :returns: the number of tasks discarded. N(Rtconnection_or_acquiretamqpt TaskConsumertpurge(RRtconn((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyR]‡s cC@s2|jdd|di|d6|d6|d6ƒdS(NtelectionRR%tidttopictaction(R'(RR`RaRbR((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyR_”stSIGTERMcK@s1|jdd|di|d6|d6|d6|S(s๊Tell all (or specific) workers to revoke a task by id. If a task is revoked, the workers will ignore the task and not execute it after all. :param task_id: Id of the task to revoke. :keyword terminate: Also terminate the process currently working on the task (if any). :keyword signal: Name of signal to send to process if terminate. Default is TERM. See :meth:`broadcast` for supported keyword arguments. trevokeRR%ttask_idt terminatetsignal(R'(RReRRfRgR*((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRd™s ic K@s"|jddtd|d||S(s“Ping all (or specific) workers. Will return the list of answers. See :meth:`broadcast` for supported keyword arguments. R;RRR(R'R((RRRR*((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyR;ฎscK@s*|jdd|di|d6|d6|S(sซTell all (or specific) workers to set a new rate limit for task by type. :param task_name: Name of task to change rate limit for. :param rate_limit: The rate limit as tasks per second, or a rate limit string (`'100/m'`, etc. see :attr:`celery.task.base.Task.rate_limit` for more information). See :meth:`broadcast` for supported keyword arguments. t rate_limitRR%t task_name(R'(RRiRhRR*((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRhนs  tdirectcK@sA|jddti|d6|d6|d6|d6|p7i|S(s`Tell all (or specific) workers to start consuming from a new queue. Only the queue name is required as if only the queue is specified then the exchange/routing key will be set to the same name ( like automatic queues do). .. note:: This command does not respect the default queue/exchange options in the configuration. :param queue: Name of queue to start consuming from. :keyword exchange: Optional name of exchange. :keyword exchange_type: Type of exchange (defaults to 'direct') command to, when empty broadcast to all workers. :keyword routing_key: Optional routing key. :keyword options: Additional options as supported by :meth:`kombu.entitiy.Queue.from_dict`. See :meth:`broadcast` for supported keyword arguments. t add_consumerR%tqueuetexchanget exchange_typet routing_key(R'tdict(RRlRmRnRotoptionsR*((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRkหs cK@s|jddi|d6|S(sTell all (or specific) workers to stop consuming from ``queue``. Supports the same keyword arguments as :meth:`broadcast`. tcancel_consumerR%Rl(R'(RRlR*((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRr๋scK@s+|jddi|d6|d6|d6|S(sZTell all (or specific) workers to set time limits for a task by type. :param task_name: Name of task to change time limits for. :keyword soft: New soft time limit (in seconds). :keyword hard: New hard time limit (in seconds). Any additional keyword arguments are passed on to :meth:`broadcast`. t time_limitR%Rithardtsoft(R'(RRiRuRtR*((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRs๕s  cK@s|jdi||S(s0Tell all (or specific) workers to enable events.t enable_events(R'(RRR*((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRvscK@s|jdi||S(s1Tell all (or specific) workers to disable events.tdisable_events(R'(RRR*((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRw scK@s|jdi|d6||S(s~Tell all (or specific) workers to grow the pool by ``n``. Supports the same arguments as :meth:`broadcast`. t pool_growRL(R'(RRLRR*((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRx scK@s|jdi|d6||S(s€Tell all (or specific) workers to shrink the pool by ``n``. Supports the same arguments as :meth:`broadcast`. t pool_shrinkRL(R'(RRLRR*((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRyscK@s$|jdi|d6|d6||S(shChange worker(s) autoscale setting. Supports the same arguments as :meth:`broadcast`. t autoscaletmaxtmin(R'(RR{R|RR*((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyRzsc K@sb|jj|ƒJ} t|p!i| }|j| ƒj|||||||d| ƒSWdQXdS(sผBroadcast a control command to the celery workers. :param command: Name of command to send. :param arguments: Keyword arguments for the command. :keyword destination: If set, a list of the hosts to send the command to, when empty broadcast to all workers. :keyword connection: Custom broker connection to use, if not set, a connection will be established automatically. :keyword reply: Wait for and return the reply. :keyword timeout: Timeout in seconds to wait for the reply. :keyword limit: Limit number of replies. :keyword callback: Callback called immediately for each reply received. tchannelN(RRZRpRVt _broadcast( RR)R%RRRRRRR}t extra_kwargsR^((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyR'&s N(RMRNRRORRRYR]t discard_allR_RPRdR;RhRkRrRsRvRwRxRyRzR'(((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyR|s,         (t__doc__t __future__RR t kombu.pidboxRt kombu.utilsRtcelery.exceptionsRtcelery.utils.textRt__all__RRtobjectRR(((s4/tmp/pip-unpacked-wheel-gV1wwp/celery/app/control.pyt s  R