fix(api): 爆款视频 API 用 celery_app.send_task() 替换直接 import worker #2105

Merged

xiaoxia merged 4 commits from fix/2105-viral-video-celery-import into develop 2026-09-30 16:22:59 +08:00

Conversation 2 Commits 4 Files Changed 2

+181 -12

xiaoxia commented 2026-09-30 15:30:58 +08:00

Owner

Copy Link

Copy Source

问题

viral_video.py 有 4 处直接 from worker_app.tasks.viral_video import ... 然后 .delay()，API 容器无 worker_app 模块，任务提交时 ModuleNotFoundError。

修复

改用 celery_app.send_task() 字符串分发，task name 与 worker 侧 @shared_task(name=...) 对齐：

• worker.run_viral_video_pipeline (generate / retry)
• worker.resume_viral_video_pipeline (confirm-intent)
• worker.run_video_style_analysis (analyze-style)

## 问题 viral_video.py 有 4 处直接 from worker_app.tasks.viral_video import ... 然后 .delay()，API 容器无 worker_app 模块，任务提交时 ModuleNotFoundError。 ## 修复 改用 celery_app.send_task() 字符串分发，task name 与 worker 侧 @shared_task(name=...) 对齐： - worker.run_viral_video_pipeline (generate / retry) - worker.resume_viral_video_pipeline (confirm-intent) - worker.run_video_style_analysis (analyze-style)

xiaoxia added 1 commit 2026-09-30 15:30:59 +08:00

fix(api): use celery_app.send_task() for viral_video enqueue instead of direct worker import ... f7f600d091

The viral_video API route module had 4 places that did
`from worker_app.tasks.viral_video import <task>` and then <task>.delay().
In the API container the worker_app package is not installed, so calling
generate/retry/confirm-intent/analyze-style would raise ModuleNotFoundError:
No module named 'worker_app'.

Switched all four call sites to celery_app.send_task() string-dispatch
(matches the existing pattern in app/core/task_enqueue.py for
worker.generate_video). Verified task names match @shared_task(name=...)
declared in worker_app/tasks/viral_video.py:
  - worker.run_viral_video_pipeline
  - worker.resume_viral_video_pipeline
  - worker.run_video_style_analysis

gitea-actions bot commented 2026-09-30 15:33:15 +08:00

Copy Link

Copy Source

🚀 预览环境已部署

项目	详情
PR号	#2105
预览链接	https://pr-2105.preview.xiaoxiajianji.com
API环境	staging

💡 预览环境使用 staging API 数据，请勿在预览环境中操作重要数据。

🔄 每次提交新代码后预览环境会自动更新。

🗑️ PR 关闭或合并后，预览环境会自动清理。

🚀 **预览环境已部署** | 项目 | 详情 | |------|------| | PR号 | #2105 | | 预览链接 | [https://pr-2105.preview.xiaoxiajianji.com](https://pr-2105.preview.xiaoxiajianji.com) | | API环境 | staging | > 💡 预览环境使用 staging API 数据，请勿在预览环境中操作重要数据。 > > 🔄 每次提交新代码后预览环境会自动更新。 > > 🗑️ PR 关闭或合并后，预览环境会自动清理。

auto-approve-bot added 1 commit 2026-09-30 15:39:51 +08:00

style: auto-format with black + isort + ruff + prettier [skip ci-format-check] 69da326ed6

xiaoxia referenced this issue from a commit 2026-09-30 15:44:08 +08:00

test(api): add unit tests for viral_video celery send_task call sites

xiaoxia added 1 commit 2026-09-30 15:44:08 +08:00

test(api): add unit tests for viral_video celery send_task call sites ... b54dda6526

Cover the 4 dispatch lines that missed diff coverage on PR #2105:
- generate  -> worker.run_viral_video_pipeline
- retry     -> worker.run_viral_video_pipeline
- confirm-intent -> worker.resume_viral_video_pipeline
- analyze-style  -> worker.run_video_style_analysis

auto-approve-bot added 1 commit 2026-09-30 15:55:50 +08:00

style: auto-format with black + isort + ruff + prettier [skip ci-format-check] 7ad722e6c6

xiaoxia merged commit 7ad722e6c6 into develop 2026-09-30 16:22:59 +08:00

gitea-actions bot commented 2026-09-30 16:27:21 +08:00

Copy Link

Copy Source

🗑️ 预览环境已清理

PR #2105 已关闭或合并，对应的预览环境已被清理。

如有需要，可以重新打开 PR 来重新生成预览环境。

🗑️ **预览环境已清理** PR #2105 已关闭或合并，对应的预览环境已被清理。 > 如有需要，可以重新打开 PR 来重新生成预览环境。

Sign in to join this conversation.

Reviewers

No Reviewers

Labels

Clear labels

architecture

架构设计

backend

后端相关

blocked

阻塞中

bug

Bug修复

ci-bug

CI本身的bug

ci-optimization

CI优化类任务

ci-pipeline

CI流水线/workflow相关

cleanup

代码清理

devops

运维/部署/CI

documentation

文档相关

feature

新功能

frontend

前端相关

P0

阻塞性，必须立即处理

P1

高优先级

P2

中优先级

P3

低优先级/后考虑

question

需要讨论确认

ready

PR CI通过，可合并

refactor

代码重构

No Label

Milestone

No items

No Milestone

Projects

Clear projects

No project

Assignees

Clear assignees

auto-approve-bot frontend-dev xiaoxia

No Assignees

3 Participants

Notifications

Subscribe

Due Date

No due date set.

Dependencies

No dependencies set.

Reference: xiaoxia/xiaoxia-saas#2105