+
    di                        ^ RI Ht ^ RIt^ RIHt ^ RIHt ^ RIHt ^ RI	H
t
 ^ RIHt ]P                  ! ]4      tR
R R	 lltR# )    )annotationsN)text)Session)get_settings)publish_campaign_run)process_campaign_taskc               8    V ^8  d   QhRRRRRRRRRRR	R
RR
RR/# )   session_defaultr   campaign_idintbusiness_id
retry_onlyboolpriority_onlylaravel_queuez
str | Nonebusiness_namereturnNone )formats   "app\utils\queue_dispatch.py__annotate__r      sb     ] ]]] ] 	]
 ] ] ] 
]    c                   \        4       pT;'       g    VP                  pVfW   V P                  \        R4      RV/4      P	                  4       p	V	'       d"   V	^ ,          '       d   \        V	^ ,          4      MR p/ p
WP                  8X  d   VP                  V
R&   \        P                  ! RRWW4./V
B  \        WW4V4       R # )NzESELECT business_name FROM businesses WHERE business_id = :bid LIMIT 1bidqueueargsr   )
r   queue_first_campaignexecuter   firststrqueue_priorityr   apply_asyncr   )r   r   r   r   r   r   r   settingsqrowoptss   &&&&&&&    r   dispatch_campaign_to_queuer)      s     ~H6666A%%XYK 
 %' 	 (+s1vvCF4D### //W%% 
B
 :m\r   )FFNN)
__future__r   logging
sqlalchemyr   sqlalchemy.ormr   
app.configr   app.utils.rabbitmq_campaignr   app.workers.tasksr   	getLogger__name__loggerr)   r   r   r   <module>r4      s6    "   " # < 3			8	$] ]r   