Update the celery task tables name

Author: wu-clan

backend/app/task/celery.py

@@ -26,8 +26,12 @@ def init_celery() -> celery.Celery:
         backend=f'db+{settings.DATABASE_TYPE + "+pymysql" if settings.DATABASE_TYPE == "mysql" else settings.DATABASE_TYPE}'  # noqa: E501
         f'://{settings.DATABASE_USER}:{settings.DATABASE_PASSWORD}@{settings.DATABASE_HOST}:{settings.DATABASE_PORT}/{settings.DATABASE_SCHEMA}',
         database_engine_options={'echo': settings.DATABASE_ECHO},
+        database_table_names={
+            'task': 'task_result',
+            'group': 'task_group_result',
+        },
         result_extended=True,
-        result_expires=0,
+        # result_expires=0,  # 任务结果自动清理
         beat_schedule=LOCAL_BEAT_SCHEDULE,
         beat_scheduler='app.task.utils.schedulers:DatabaseScheduler',
         task_cls='app.task.tasks.base:TaskBase',

backend/app/task/model/task.py

@@ -32,8 +32,8 @@ class TaskScheduler(Base):
     args: Mapped[str | None] = mapped_column(JSON(), comment='任务可接收的位置参数')
     kwargs: Mapped[str | None] = mapped_column(JSON(), comment='任务可接收的关键字参数')
     queue: Mapped[str | None] = mapped_column(String(255), comment='CELERY_TASK_QUEUES 中定义的队列')
-    exchange: Mapped[str | None] = mapped_column(String(255), comment='低级别 AMQP 路由的交换机覆盖')
-    routing_key: Mapped[str | None] = mapped_column(String(255), comment='低级别 AMQP 路由的路由键覆盖')
+    exchange: Mapped[str | None] = mapped_column(String(255), comment='低级别 AMQP 路由的交换机')
+    routing_key: Mapped[str | None] = mapped_column(String(255), comment='低级别 AMQP 路由的路由密钥')
     start_time: Mapped[datetime | None] = mapped_column(DateTime(timezone=True), comment='任务开始触发的时间')
     expire_time: Mapped[datetime | None] = mapped_column(DateTime(timezone=True), comment='任务不再触发的截止时间')
     expire_seconds: Mapped[int | None] = mapped_column(comment='任务不再触发的秒数时间差')

backend/app/task/schema/task.py

@@ -17,8 +17,8 @@ class TaskSchedulerParam(SchemaBase):
     args: str | None = Field(default='[]', description='任务可接收的位置参数')
     kwargs: str | None = Field(default='{}', description='任务可接收的关键字参数')
     queue: str | None = Field(default=None, description='CELERY_TASK_QUEUES 中定义的队列')
-    exchange: str | None = Field(default=None, description='低级别 AMQP 路由的交换机覆盖')
-    routing_key: str | None = Field(default=None, description='低级别 AMQP 路由的路由键覆盖')
+    exchange: str | None = Field(default=None, description='低级别 AMQP 路由的交换机')
+    routing_key: str | None = Field(default=None, description='低级别 AMQP 路由的路由密钥')
     start_time: datetime | None = Field(default=None, description='任务开始触发的时间')
     expire_time: datetime | None = Field(default=None, description='任务不再触发的截止时间')
     expire_seconds: int | None = Field(default=None, description='任务不再触发的秒数时间差')