"""Database models used by the SQLAlchemy result store backend."""fromdatetimeimportdatetime,timezoneimportsqlalchemyassafromsqlalchemy.typesimportPickleTypefromceleryimportstatesfrom.sessionimportResultModelBase__all__=('Task','TaskExtended','TaskSet')
[文档]classTaskExtended(Task):"""For the extend result."""__tablename__='celery_taskmeta'__table_args__={'sqlite_autoincrement':True,'extend_existing':True}name=sa.Column(sa.String(155),nullable=True)args=sa.Column(sa.LargeBinary,nullable=True)kwargs=sa.Column(sa.LargeBinary,nullable=True)worker=sa.Column(sa.String(155),nullable=True)retries=sa.Column(sa.Integer,nullable=True)queue=sa.Column(sa.String(155),nullable=True)