o I<V @sddlmZmZddlmZddlmZmZddlm Z ddl m Z ddl m Z ddlmZddlmZmZdd lmZdd lZ d d Zd dZddZddZddZddZddZd S))absolute_importunicode_literalswraps) HttpResponseHttp404) serialize)states)tasks) AsyncResult)get_full_cls_namekwdict) safe_reprNcCstt|ddS)Nzapplication/json) content_type)rr)responser@/var/www/html/env/lib/python3.10/site-packages/djcelery/views.py JsonResponsesrcsfdd}|S)aDecorator turning any task into a view that applies the task asynchronously. Keyword arguments (via URLconf, etc.) will supercede GET or POST parameters when there are conflicts. Returns a JSON dictionary containing the keys ``ok``, and ``task_id``. csTt|jdkr |jp |j}tdd|Dfi|}j|d}td|jdS)NPOSTcss|] \}}||fVqdS)Nr).0kvrrr %sz.task_view.._applier..)kwargstrue)oktask_id) r methodrGETdict iteritems apply_asyncrr)requestoptionsrresulttaskrr_applier!s  ztask_view.._applierr)r&r'rr%r task_views r(cCs0zt|}Wn tytdwt||S)zView applying a task. **Note:** Please use this with caution. Preferably you shouldn't make this publicly accessible without ensuring your code is safe! zapply: no such task)r KeyErrorrr()r" task_namer&rrrapply,s    r+cCstd|t|diS)z+Returns task execute status in JSON format.r&)idexecuted)rr successful)r"rrrris_task_successful:s  r/cCs\t|}|j|j}}t|||d}|tjvr(|j}|t|t |j |dt d|iS)z.Returns task status and result in JSON format.)r,statusr$)r$exc tracebackr&) r stater$rr EXCEPTION_STATESr2updaterr __class__r)r"rr$r3retval response_datar2rrr task_statusBs   r9cCstttdS)z2View returning all defined tasks as a JSON object.)regularperiodic)rr r:keysr;)r"rrrregistered_tasksOs  r=cstfdd}|S)aQDecorator turning a function into a task webhook. If an exception is raised within the function, the decorated function catches this and returns an error JSON response, otherwise it returns the result as a JSON response. Example: .. code-block:: python @task_webhook def add(request): x = int(request.GET['x']) y = int(request.GET['y']) return x + y def view(request): response = add(request) print(response.content) Gives:: "{'status': 'success', 'retval': 100}" c s^z |i|}Wnty%}zdt|d}WYd}~t|Sd}~wwd|d}t|S)Nfailure)r0reasonsuccess)r0r7) Exceptionrr)argsrr7r1rfunrr_innerqs ztask_webhook.._innerr)rDrErrCr task_webhookUs rF) __future__rr functoolsr django.httprranyjsonrceleryr celery.registryr celery.resultr celery.utilsr r celery.utils.encodingr celery.taskrr(r+r/r9r=rFrrrrs"