27 lines
695 B
Python
27 lines
695 B
Python
|
"""手动触发 worker-general 定时任务：生成反馈报告
|
||
|
|
|
||
|
|
用法:
|
||
|
|
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_general_broker
|
||
|
|
from v1.feedback.tasks import generate_daily_feedback_report
|
||
|
|
|
||
|
|
|
||
|
|
def main():
|
||
|
|
task = generate_daily_feedback_report.kiq()
|
||
|
|
result = worker_general_broker.wait_result(task, timeout=120)
|
||
|
|
print(f"Task result: {result.return_value}")
|
||
|
|
|
||
|
|
|
||
|
|
if __name__ == "__main__":
|
||
|
|
main()
|