a
    Cg                     @   s   U d dl Z e   d dlZd dlmZ d dlmZ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mZmZmZ ejeZg d	ZG d
d dee Ze ZeeeZeed< dS )    N)Optional)BaseConnectionHandlerConnectionProxy)import_string   )BaseTaskBackend)InvalidTaskBackendError)DEFAULT_QUEUE_NAMEDEFAULT_TASK_BACKEND_ALIASResultStatusTask
TaskResulttask)tasksdefault_task_backendr
   r	   r   r   r   r   c                       s@   e Zd ZdZeZee ed fddZe	e
dddZ  ZS )TasksHandlerZTASKS)settingsreturnc                    s2   zt  |W S  ty,   tddii Y S 0 d S )NBACKENDz0django_tasks.backends.immediate.ImmediateBackend)superconfigure_settingsAttributeErrorr
   )selfr   	__class__ T/var/www/lab.imftr.de/x/nb_venv/lib/python3.9/site-packages/django_tasks/__init__.pyr   )   s    zTasksHandler.configure_settings)aliasr   c              
   C   sf   | j | }|d }zt|}W n: tyX } z"td| d| |W Y d }~n
d }~0 0 |||dS )Nr   zCould not find backend 'z': )r   params)r   r   ImportErrorr   )r   r   r   backendZbackend_clser   r   r   create_connection5   s    
zTasksHandler.create_connection)__name__
__module____qualname__Zsettings_namer   Zexception_classr   dictr   strr   r"   __classcell__r   r   r   r   r   %   s   r   r   )Zdjango_stubs_extZmonkeypatchimportlib.metadata	importlibtypingr   Zdjango.utils.connectionr   r   Zdjango.utils.module_loadingr   Zbackends.baser   
exceptionsr   r   r	   r
   r   r   r   metadataversionr#   __version____all__r   r   r   __annotations__r   r   r   r   <module>   s   
 	