
    (\im                        d dl Z d dlZd dlmZ d dlmZ d dlmZmZ ddl	m
Z
  e j                  d      Z e       Z e       Z e       Z ee      d        Z ee      d	        Z ee      d
        Z ee      d        Zy)    N)Local)setting_changed)Signalreceiver   )TaskResultStatuszdjango.tasksc                 t    | dk(  r3ddl m} |j                  d      x|_        |_        t               |_        yy)z:Reset the connection handler whenever the settings change.TASKSr   )task_backendsN) r   configure_settings	_settingssettingsr   _connections)settingkwargsr   s      d/home/devuser/fomin/mqttuser/mqtt_project/myenv/lib/python3.12/site-packages/django/tasks/signals.pyclear_tasks_handlersr      s?     '# ,,T2	
-"8 &+W"     c                     t         j                  d|j                  |j                  j                  |j
                         y )Nz&Task id=%s path=%s enqueued backend=%s)loggerdebugidtaskmodule_pathbackendsendertask_resultr   s      r   log_task_enqueuedr       s0    
LL0$$	r   c                     t         j                  d|j                  |j                  j                  |j
                         y )NTask id=%s path=%s state=%s)r   infor   r   r   statusr   s      r   log_task_startedr%   (   s0    
KK%$$	r   c           	      $   t         j                  |j                  t        j                  k(  rt
        j                  nt
        j                  d|j                  |j                  j                  |j                  t        j                                y )Nr"   )exc_info)r   logr$   r   FAILEDloggingERRORINFOr   r   r   sysr'   r   s      r   log_task_finishedr.   2   se    
JJ !!%5%<%<< MM%$$  r   )r*   r-   asgiref.localr   django.core.signalsr   django.dispatchr   r   baser   	getLoggerr   task_enqueuedtask_finishedtask_startedr   r    r%   r.    r   r   <module>r8      s     
  / , "			>	*x 
/- - 
-  
,  
- r   