eryao/backend/scripts/trigger_feedback_report.py

"""手动触发 worker-agent 定时任务：生成反馈报告

用法:
    cd /home/qzl/Code/eryao/.worktrees/feat-user-feedback
    PYTHONPATH=backend/src uv run python backend/scripts/trigger_feedback_report.py
"""

from __future__ import annotations

import sys
from pathlib import Path

sys.path.insert(0, str(Path(__file__).resolve().parent.parent / "src"))

from core.taskiq.app import worker_agent_broker
from v1.feedback.tasks import generate_daily_feedback_report


def main():
    task = generate_daily_feedback_report.kiq()
    result = worker_agent_broker.wait_result(task, timeout=120)
    print(f"Task result: {result.return_value}")


if __name__ == "__main__":
    main()