`f dZddlmZddlZddlmZddlmZddlm Z dZ Gd d e Z Gd d e Z Gd de Z dS)z)formatr&s r__repr__z Task.__repr__)s5<>#4 9 9 9Bbi  #t444G RYyry}}fn = = =F RYzD 1 1 1F "+x#+?TCCCI "'D111I   CCC777[777rrczeZdZdZdZdddZejejddZ ejej dZ ejej dZ ejejddZ ejejdZejejddZfdZxZS)r zFor the extend result.r T)r extend_existingrrc t}||j|j|j|j|j|jd|S)N)r1argskwargsworkerretriesqueue) superr'updater1rJrKrLrMrN)r task_dict __class__s rr'zTaskExtended.to_dict@s^GGOO%% IIkk|Z      r)r7r8r9r:r0r;r<r=r@r1 LargeBinaryrJrKrLr>rMrNr' __classcell__)rRs@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         rr c4eZdZdZdZddiZejejej dddZ ejej ddZ eje d Zejejejd Zd Zd Zd ZeddZdS)r zTaskSet result.celery_tasksetmetar Ttaskset_id_sequence)rrrrr)rrc"||_||_dSr) taskset_idr#)rrYr#s rrzTaskSet.__init__Zs$ rc,|j|j|jdS)NrYr#r%r[r&s rr'zTaskSet.to_dict^s /k   rcd|jdS)Nz )rYr&s rr*zTaskSet.__repr__es.DO....rNcf||j_||jj_|p|j|j_dSrr,r2s rr4zTaskSet.configurehr5rr6)r7r8r9r:r0r;r<r=r>r?r/r@rYrr#rBrrCr%rr'r*rEr4rFrrr r Ms(M,d3N 2:{r{+@AA!%4 9 9 9B929S>>$777J RYzD 1 1 1F "+x#')))I   ///777[777rr )r:r sqlalchemyr<sqlalchemy.typesrceleryrsessionr__all__rr r rFrrrdsBB''''''$$$$$$ -"7"7"7"7"7?"7"7"7J4477777o77777r