o wvXj @sXdZddlmZmZddlmZddlmZddlm Z ddl m Z GdddeZ d S) zEThe ``celery call`` program used to send tasks from the command-line.)absolute_importunicode_literals)loads)Command)string_t) maybe_iso8601c@s:eZdZdZdZdZddZddZ    d d d ZdS) callzCall a task by name. Examples: .. code-block:: console $ celery call tasks.add --args='[2, 2]' $ celery call tasks.add --args='[2, 2]' --countdown=10 z posargscCs|d}|jdddd|jdddd|jd d d|jd td d |jdddf|jddddf|d}|jddd|jddd|jddddS)NzCalling Optionsz--argsz-azpositional arguments (json).)helpz--kwargsz-kzkeyword arguments (json).z--etazscheduled time (ISO-8601).z --countdownz$eta in seconds from now (float/int).)typer z --expiresz!expiry time (ISO-8601/float/int).z --serializerjsonzdefaults to json.)defaultr zRouting Optionsz--queuezcustom queue name.z --exchangezcustom exchange name.z --routing-keyzcustom routing key.)add_argument_group add_argumentfloat)selfparsergrouproptsrL/var/www/html/myproject/venv/lib/python3.10/site-packages/celery/bin/call.py add_argumentss4  zcall.add_argumentscOs|j|fi|dS)N) _send_task)rname_kwargsrrrrun3szcall.runNc Kst|tr t|n|}t|trt|n|}zt| } Wnttfy8zt| } Wn ttfy5wYnw||jj ||pBd|pEi|||||t| | d j dS)Nr) argsr countdown serializerqueueexchange routing_keyetaexpires) isinstancerrr TypeError ValueErrorroutapp send_taskid) rrrrrrr r!r"r#r$rrrrr6s2     zcall._send_task) NNNNNNNNN) __name__ __module__ __qualname____doc__r args_namerrrrrrrr s rN) r/ __future__rrkombu.utils.jsonrcelery.bin.baser celery.fivercelery.utils.timerrrrrrs