o ©D®fB ã@sxdZddlmZmZddlZddlmZddlmZddl m Z dZGd d „d e ƒZGdd„deƒZ Gd d„de ƒZdS)z)Úformatr$rrrÚ__repr__)rz Task.__repr__NcCó$||j_||jj_|p |j|j_dSr©Ú __table__ÚschemaÚidrÚ __tablename__Úname©Úclsr+r.rrrÚ configure,ó zTask.configure©NN)Ú__name__Ú __module__Ú__qualname__Ú__doc__r-Ú__table_args__ÚsaÚColumnÚIntegerÚSequencer,ÚStringrrÚPENDINGr rr!ÚDateTimerÚnowrÚutcr#ÚTextr"rr%r'Úclassmethodr1rrrrrs&ÿÿ rcsšeZdZdZdZdddœZeje d¡ddZ ejej ddZejej ddZeje d¡ddZ ejejddZeje d¡ddZ‡fdd„Z‡ZS) r zFor the extend result.rT)rÚextend_existingrrc s2tƒ ¡}| |j|j|j|j|j|jdœ¡|S)N)r.ÚargsÚkwargsÚworkerÚretriesÚqueue) Úsuperr%Úupdater.rErFrGrHrI)rÚ task_dict©Ú __class__rrr%@s úzTaskExtended.to_dict)r4r5r6r7r-r8r9r:r=r.ÚLargeBinaryrErFrGr;rHrIr%Ú __classcell__rrrMrr 3s r c@s˜eZdZdZdZddiZejeje d¡dddZ eje d¡ddZeje dd Zejeje ej¡dd Zdd„Zd d„Zdd„Zeddd„ƒZdS)r zTaskSet result.Úcelery_tasksetmetarTÚtaskset_id_sequence)rrrrr)rrcCs||_||_dSr)Ú taskset_idr!)rrSr!rrrrZs zTaskSet.__init__cCs|j|j|jdœS)N©rSr!r#rTr$rrrr%^sýzTaskSet.to_dictcCsd|j›dS)Nz )rSr$rrrr'eszTaskSet.__repr__NcCr(rr)r/rrrr1hr2zTaskSet.configurer3)r4r5r6r7r-r8r9r:r;r<r,r=rSrr!r?rr@rrAr#rr%r'rCr1rrrrr Ms"ÿÿr )r7rrÚ sqlalchemyr9Úsqlalchemy.typesrÚceleryrÚsessionrÚ__all__rr r rrrrÚs%