ó P'—^c @@sdZddlmZddlZddlZy ddlmZmZmZWn7e k r‡ddl mZddlmZmZnXddl m Z m ZddlmZmZdd lmZd d d d ddgZeddgƒZeeƒZejddkr/ddlmZmZd„ZnddlmZmZd„Zd efd„ƒYZ d efd„ƒYZ!d e fd„ƒYZ"ej#d„Z$de%fd„ƒYZ&d e%fd„ƒYZ'e ddde(d dd!dd"e*ƒddd#„ƒZ+de&fd$„ƒYZ,dS(%sN celery.task.http ~~~~~~~~~~~~~~~~ Webhook task implementation. i(tabsolute_importN(t parse_qslt urlencodeturlparse(R(RR(t shared_taskt __version__(titemstreraise(tget_task_loggertInvalidResponseErrortRemoteExecuteErrortUnknownStatusErrort HttpDispatchtdispatchtURLtGETtHEADi(tRequestturlopencC@st|tƒst|ƒS|S(N(t isinstancetdict(ttup((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pytutf8dict#s cC@std„|DƒƒS(sYWith a dict's items() tuple return a new dict with any utf-8 keys/values encoded.cs@sH|]>\}}|jdƒt|tƒr9|jdƒn|fVqdS(sutf-8N(tencodeRtunicode(t.0tktv((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pys 0s(R(R((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyR,scB@seZdZRS(s+The remote server gave an invalid response.(t__name__t __module__t__doc__(((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyR 5scB@seZdZRS(s$The remote task gave a custom error.(RRR(((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyR 9scB@seZdZRS(s)The remote server gave an unknown status.(RRR(((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyR =scC@s¹|stdƒ‚ny||ƒ}Wn9tk r`}tttt|ƒƒtjƒdƒnX|d}|dkr|dS|dkr£t|jdƒƒ‚ntt|ƒƒ‚dS( s3Extract the response text from a raw JSON response.sEmpty responseitstatustsuccesstretvaltfailuretreasonN( R t ValueErrorRtstrtsystexc_infoR tgetR (t raw_responsetloadstpayloadtexcR((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pytextract_responseAs !   t MutableURLcB@s)eZdZd„Zd„Zd„ZRS(sIObject wrapping a Uniform Resource Locator. Supports editing the query parameter list. You can convert the object back to a string, the query will be properly urlencoded. Examples >>> url = URL('http://www.google.com:6580/foo/bar?x=3&y=4#foo') >>> url.query {'x': '3', 'y': '4'} >>> str(url) 'http://www.google.com:6580/foo/bar?y=4&x=3#foo' >>> url.query['x'] = 10 >>> url.query.update({'George': 'Costanza'}) >>> str(url) 'http://www.google.com:6580/foo/bar?y=4&x=10&George=Costanza#foo' cC@s/t|ƒ|_tt|jdƒƒ|_dS(Ni(RtpartsRRtquery(tselfturl((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyt__init__hscC@s®|j\}}}}}}ttt|jƒƒƒ}|d||pId|r^dj|ƒnd|rvdj|ƒnd|rŽdj|ƒndg}djd„|DƒƒS(Ns://t/s;{0}ts?{0}s#{0}cs@s|]}|r|VqdS(N((Rtc((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pys ss(R/RRRR0tformattjoin(R1tschemetnetloctpathtparamsR0tfragmentt components((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyt__str__lscC@sdjt|ƒj|ƒS(Ns <{0}: {1}>(R7ttypeR(R1((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyt__repr__us(RRRR3R?RA(((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyR.Ts  cB@sPeZdZdjdeƒZdZd„Zd„Zd„Z e d„ƒZ RS(s&Make task HTTP request and collect the task result. :param url: The URL to request. :param method: HTTP method used. Currently supported methods are `GET` and `POST`. :param task_kwargs: Task keyword arguments. :param logger: Logger used for user/system feedback. scelery/{version}tversionicK@s7||_||_||_|jdƒp-t|_dS(Ntlogger(R2tmethodt task_kwargsR(RC(R1R2RDREtkwargs((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyR3†s   cC@sUt||ƒ}x-t|jƒD]\}}|j||ƒqWt|ƒ}|jƒS(s-Perform HTTP request and return the response.(RRt http_headerst add_headerRtread(R1R2RDR<trequesttkeytvaltresponse((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyt make_requestŒs  cC@s}t|jƒ}d}|jtkr:|jj|jƒntt t |jƒƒƒ}|j t |ƒ|j|ƒ}t |ƒS(s$Dispatch callback and return result.N(R.R2tNoneRDt GET_METHODSR0tupdateRERRRRNR%R-(R1R2R<R)((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyR ”scC@si|jd6}|S(Ns User-Agent(t user_agent(R1theaders((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyRGŸs( RRRR7tcelery_versionRRttimeoutR3RNR tpropertyRG(((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyR ys    tnamescelery.http_dispatchtbindR2RDtaccept_magic_kwargscK@s(t|p|j|p|j|ƒjƒS(séTask dispatching to an URL. :keyword url: The URL location of the HTTP callback task. :keyword method: Method to use when dispatching the callback. Usually `GET` or `POST`. :keyword \*\*kwargs: Keyword arguments to pass on to the HTTP callback. .. attribute:: url If this is set, this is used as the default URL for requests. Default is to require the user of the task to supply the url as an argument, as this attribute is intended for subclasses. .. attribute:: method If this is set, this is the default method used for requests. Default is to require the user of the task to supply the method as an argument, as this attribute is intended for subclasses. (R R2RDR (R1R2RDRF((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyR ¥scB@s5eZdZdZddd„Zd„Zd„ZRS(sÒHTTP Callback URL Supports requesting an URL asynchronously. :param url: URL to request. :keyword dispatcher: Class used to dispatch the request. By default this is :func:`dispatch`. cC@sitt|ƒj|ƒ||_|p+|j|_|jdkre|jrY|jjdnt|_ndS(Nscelery.http_dispatch(tsuperRR3tappt dispatcherROttasksR (R1R2R\R[((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyR3Ís  cK@s|jjt|ƒd|S(NR(R\tdelayR%(R1RF((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyt get_asyncØscK@s|jjt|ƒd|S(NtPOST(R\R^R%(R1RF((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyt post_asyncÛsN(RRRROR\R3R_Ra(((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyRÁs   (-Rt __future__RtanyjsonR&t urllib.parseRRRt ImportErrorturllibtceleryRRRTt celery.fiveRRtcelery.utils.logRt__all__t frozensetRPRRCt version_infoturllib.requestRRRturllib2t ExceptionR R R R*R-tobjectR.R tTrueROtFalseR R(((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/task/http.pyts<        %,