> i dZddlmZddlZddlmZddlmZddlm Z dZ Gd d e Z Gd d e Z Gd de Z y)z)formatr&s r__repr__z Task.__repr__)s5<#4 9Bbii  #t4G RYYyryy}fnn =F RYYzD 1F "++x#+??TCI "''D1I C77rrceZdZdZdZdddZejejddZ ejejdZ ejejdZ ejejddZ ejejdZejejddZfdZxZS)r zFor the extend result.r T)r extend_existingrrc t|}|j|j|j|j |j |j|jd|S)N)r1argskwargsworkerretriesqueue) superr'updater1rJrKrLrMrN)r task_dict __class__s rr'zTaskExtended.to_dict@sTGO% IIIIkkkk||ZZ   r)r7r8r9r:r0r;r<r=r@r1 LargeBinaryrJrKrLr>rMrNr' __classcell__)rRs@rr r 3s %M.2tLN 299YRYYs^d 3D 299R^^d 3D RYYr~~ 5F RYYyryy~ 5Fbii T2G BIIibiint 4E  rr cbeZdZdZdZddiZejejejdddZ ejejddZ eje d Zejejej"d Zd Zd Zd ZeddZy)r zTaskSet result.celery_tasksetmetar Ttaskset_id_sequence)rrrrr)rrc ||_||_yr) taskset_idr#)rrYr#s rrzTaskSet.__init__Zs$ rcJ|j|j|jdS)NrYr#r%r[r&s rr'zTaskSet.to_dict^s!//kk  rc"d|jdS)Nz )rYr&s rr*zTaskSet.__repr__esDOO,A..rNc||j_||jj_|xs |j|j_yrr,r2s rr4zTaskSet.configurehr5rr6)r7r8r9r:r0r;r<r=r>r?r/r@rYrr#rBrrCr%rr'r*rEr4rFrrr r Ms(M,d3N 2::{r{{+@A!%4 9B9299S>$7J RYYzD 1F "++x#')I /77rr )r:r sqlalchemyr<sqlalchemy.typesrceleryrsessionr__all__rr r rFrrrdsAB'$ -"7?"7J447o7r