jdZddlmZddlZddlZddlmZddlmZm Z m Z m Z ddl m Z ejeZd dZd dZd d Zy) zAValidation helpers when a shipment moves from draft to published.) annotationsN) transaction)is_valid_country_codenormalize_country_code$operational_region_error_for_country$return_trip_error_for_pickup_country)#maybe_fill_country_code_from_coordscddlm}ddlm}ddlm} |j j|}|j|jjk7rdd iSd}d} t||} ||}||d S#|j$rddicYSwxYw#t$rtjd |YHwxYw#t$rtjd |YdwxYw) zNDispatch rate requests and nearby-load notifications for a published shipment.r)Shipment)#dispatch_rate_requests_for_shipment)'notify_nearby_transporters_new_shipment)pkerror not_foundskipped not_publishedz,Rate request dispatch failed for shipment %sz)NEARBY_LOAD notify failed for shipment %s) rate_requestsnearby_notified) core.modelsr core.rate_distributionr api.notifyr objectsget DoesNotExiststatusStatus PUBLISHEDlen Exceptionlogger exception) shipment_idr r r shipment rate_count nearby_counts //var/www/html/truck-me/core/shipment_publish.py!run_shipment_publish_side_effectsr's$JB&##'';'7(//333?++JLVxH (L II!  &%%& VGUV SDkRSs5A;B.B9;BBB65B69CCcHfdfd}tj|y)zWRun publish side effects after commit; prefer Celery, fall back to a background thread.ch ty#t$rtjdYywxYw)Nz2Inline publish side effects failed for shipment %s)r'rr r!)r"sr& _run_inlinez:enqueue_shipment_publish_side_effects.._run_inline3s4 ` -k : `   QS^ _ `s 11c ddlm}|jy#t$rF}tj d|t jdjYd}~yd}~wwxYw)Nr)&run_shipment_publish_side_effects_taskzXCelery enqueue failed for shipment %s publish side effects (%s); using background threadT)targetdaemon) core.tasksr,delayrr warning threadingThreadstart)r,excr*r"s r& _dispatchz8enqueue_shipment_publish_side_effects.._dispatch9s_ F I 2 8 8 E F NNj    K = C C E E  Fs A*r]sEG"! ?   8 $J6%2;r9