QjB dZddlmZmZddlZddlmZddlmZddl m Z dZ Gd d e Z Gd d e Z Gd de Zy)z)formatr's r__repr__z Task.__repr__)s5<#4 9Bbii  #t4G RYYyryy}fnn =F RYYzD 1F "++|x||HLL/I#/8<< #=NI "''D1I C77r r ceZdZdZdZdddZejejddZ ejejdZ ejejdZ ejejddZ ejejdZejejddZfdZxZS)r zFor the extend result.r T)rextend_existingrrc t|}|j|j|j|j |j |j|jd|S)N)r2argskwargsworkerretriesqueue) superr(updater2rLrMrNrOrP)r task_dict __class__s rr(zTaskExtended.to_dict@sTGO% IIIIkkkk||ZZ   r )r8r9r:r;r1r<r=r>rAr2 LargeBinaryrLrMrNr?rOrPr( __classcell__)rTs@rr r 3s %M.2tLN 299YRYYs^d 3D 299R^^d 3D RYYr~~ 5F RYYyryy~ 5Fbii T2G BIIibiint 4E  r r ceZdZdZdZddiZejejejdddZ ejejddZ eje d Zejejej"ej&d Zd Zd Zd ZeddZy)r zTaskSet result.celery_tasksetmetarTtaskset_id_sequence)rrrrr)rrc ||_||_yr) taskset_idr$)rr[r$s rrzTaskSet.__init__Zs$ r cJ|j|j|jdS)Nr[r$r&r]r's rr(zTaskSet.to_dict^s!//kk  r c"d|jdS)Nz )r[r's rr+zTaskSet.__repr__esDOO,A..r Nc||j_||jj_|xs |j|j_yrr-r3s rr5zTaskSet.configurehr6r r7)r8r9r:r;r1r<r=r>r?r@r0rAr[rr$rCrrDrrEr&rr(r+rGr5rHr rr r Ms(M,d3N 2::{r{{+@A!%4 9B9299S>$7J RYYzD 1F "++|x||HLL/I#')I /77r r )r;rr sqlalchemyr=sqlalchemy.typesrceleryrsessionr__all__r r r rHr rrfsAB''$ -"7?"7J447o7r