o
    ËÉhú  ã                	   @   sÔ   d dl Z d dlmZ d dlmZ d dlmZ d dlmZ d dl	m
Z
mZmZ ddlmZmZ e  d	¡Zeeƒd
ededdfdd„ƒZeeƒdee
 dededdfdd„ƒZeeƒdee
 dededdfdd„ƒZdS )é    N)ÚType)ÚLocal)Úsetting_changed)Úreceiver)ÚBaseTaskBackendÚResultStatusÚ
TaskResulté   )Útask_enqueuedÚtask_finishedÚdjango_tasksÚsettingÚkwargsÚreturnc                 K   s6   | dkrddl m} | d¡ |_|_tƒ |_dS dS )zC
    Reset the connection handler whenever the settings change
    ÚTASKSr   )ÚtasksN)r   r   Úconfigure_settingsÚ	_settingsÚsettingsr   Ú_connections)r   r   r   © r   ú\/var/www/html/ndineBlogger/venv/lib/python3.10/site-packages/django_tasks/signal_handlers.pyÚclear_tasks_handlers   s
   ür   ÚsenderÚtask_resultc                 K   s   t  d|j|jj|j¡ d S )Nz&Task id=%s path=%s enqueued backend=%s)ÚloggerÚdebugÚidÚtaskÚmodule_pathÚbackend)r   r   r   r   r   r   Úlog_task_enqueued   s   ür!   c                 K   s4   |j tjkr
tj}ntj}|d|j|jj|j ƒ d S )NzTask id=%s path=%s state=%s)	Ústatusr   ÚFAILEDr   Ú	exceptionÚinfor   r   r   )r   r   r   Ú
log_methodr   r   r   Úlog_task_finished'   s   ür'   )ÚloggingÚtypingr   Úasgiref.localr   Údjango.core.signalsr   Údjango.dispatchr   r   r   r   r   Úsignalsr
   r   Ú	getLoggerr   ÚstrÚdictr   r!   r'   r   r   r   r   Ú<module>   s<    
ÿÿÿþÿÿÿþ