+
    i                        ^ RI Ht ^ RIt^ RIHtHt ^ RIHt ^ RIH	t	 ^ RI
Ht ]P                  ! ]4      t]P                  ! RR^R	R
R7      RR R ll4       t]P                  ! RRR7      R 4       tR# )    )annotationsN)session_scope_clustersession_scope_default)campaign_core)run_campaign)
celery_appprocess_campaignTi  i  )namebindmax_retries
time_limitsoft_time_limitc               (    V ^8  d   QhRRRRRRRR/# )   campaign_idintbusiness_id
retry_onlyboolpriority_only )formats   "app\workers\tasks.py__annotate__r      s2        	
     c                   \        4       ;_uu_ 4       p\        4       ;_uu_ 4       p\        VV\        V4      \        V4      R R R R \	        V4      \	        V4      4
      pV'       dW   \        V\        4      '       dA   VP                  R4      RJ d,   \        P                  ! V\        V4      \        V4      V4       VuuR R R 4       uuR R R 4       #   + '       g   i     M; iR R R 4       R #   + '       g   i     R # ; i)NsuccessT)
r   r   r   r   r   
isinstancedictgetr   update_waiting_time_after_retry)selfr   r   r   r   sdscresults   &&&&&   r   process_campaign_taskr&      s     
	 	 B(=(?(?2
 *VT22vzz)7LPT7T99"c+>NPST_P`bhi )@(?	 	 (?(?	 	 	 	 s#   C0BC	>
C0C#C00D	process_retry_calls_croni  )r
   r   c                 0    \         P                  R4       R# )z;Enqueue from full cron implementation in router (optional).uI   process_retry_calls_cron stub — use HTTP cron or expand to call serviceN)loggerinfor   r   r   r'   r'   '   s     KK[\r   )FF)
__future__r   loggingapp.databaser   r   app.servicesr   app.services.campaign_servicer   app.workers.celery_appr   	getLogger__name__r)   taskr&   r'   r   r   r   <module>r4      sr    "  E & 6 -			8	$ (tteij k2 0TB] C]r   