{kfB dZddlmZmZddlZddlmZddlmZddl m Z dZ Gd d e Z Gd d e Z Gd de ZdS)z)formatr's r__repr__z Task.__repr__)s5<>#4 9 9 9Bbi  #t444G RYyry}}fn = = =F RYzD 1 1 1F "+|x|HL/I/I#/8< #=#=NNNI "'D111I   CCC777[777r r czeZdZdZdZdddZejejddZ ejej dZ ejej dZ ejejddZ ejejdZejejddZfdZxZS)r zFor the extend result.r T)rextend_existingrrc t}||j|j|j|j|j|jd|S)N)r2argskwargsworkerretriesqueue) superr(updater2rLrMrNrOrP)r task_dict __class__s rr(zTaskExtended.to_dict@s^GGOO%% IIkk|Z      r )r8r9r:r;r1r<r=r>rAr2 LargeBinaryrLrMrNr?rOrPr( __classcell__)rTs@rr r 3s  %M.2tLLN 29YRYs^^d 3 3 3D 29R^d 3 3 3D RYr~ 5 5 5F RYyry~~ 5 5 5Fbi T222G BIibinnt 4 4 4E         r r cPeZdZdZdZddiZejejej dddZ ejej ddZ eje d Zejejejejd Zd Zd Zd ZeddZdS)r zTaskSet result.celery_tasksetmetarTtaskset_id_sequence)rrrrr)rrc"||_||_dSr) taskset_idr$)rr[r$s rrzTaskSet.__init__Zs$ r c,|j|j|jdS)Nr[r$r&r]r's rr(zTaskSet.to_dict^s /k   r cd|jdS)Nz )r[r's rr+zTaskSet.__repr__es.DO....r Ncf||j_||jj_|p|j|j_dSrr-r3s rr5zTaskSet.configurehr6r r7)r8r9r:r;r1r<r=r>r?r@r0rAr[rr$rCrrDrrEr&rr(r+rGr5rHr rr r Ms (M,d3N 2:{r{+@AA!%4 9 9 9B929S>>$777J RYzD 1 1 1F "+|x|HL/I/I#')))I   ///777[777r r )r;rr sqlalchemyr=sqlalchemy.typesrceleryrsessionr__all__r r r rHr rrfsBB''''''''''''''$$$$$$ -"7"7"7"7"7?"7"7"7J4477777o77777r