a
    mi                     @   s    d dl mZ edZdd ZdS )    )CeleryZ	trackreplc              
      sJ   t jj jd  jd dddgdddd G  fdddt j}|t _t S )	NCELERY_BROKER_URLCELERY_RESULT_BACKENDjsonT   )Z
broker_urlZresult_backendZtask_serializerZresult_serializerZaccept_contentZtask_track_startedZtask_acks_lateZworker_prefetch_multiplierc                       s   e Zd Z fddZdS )z init_celery.<locals>.ContextTaskc                    s<        | j|i |W  d    S 1 s.0    Y  d S )N)app_contextrun)selfargskwargsapp K/home/japhy/trackingScienceReplication.artiswrong.com/app/tasks/__init__.py__call__   s    
z)init_celery.<locals>.ContextTask.__call__N)__name__
__module____qualname__r   r   r   r   r   ContextTask   s   r   )
celery_appZconfupdateconfigTask)r   r   r   r   r   init_celery   s    r   N)Zceleryr   r   r   r   r   r   r   <module>   s   