mirror of
https://github.com/ThearchyHelios/AgentLab.git
synced 2026-11-15 22:21:59 +00:00
ThearchyHelios
22 lines
1.0 KiB
Python
22 lines
1.0 KiB
Python
"""数据源的定时维护：探查 → 剖析需要的表 → 取值观察（docs/design/next-round/03-数据接入与目录维护.md B4）。
|
|
|
|
scheduler/service.py 按目标种类导入本模块（_TARGET_MODULES）：fire 到点发起一次，check_target 建任务时核对目标。
|
|
第 3 波 W3-a 填；填之前照实记「当前版本还不能按时发起这类目标」，不发起。
|
|
"""
|
|
from __future__ import annotations
|
|
|
|
from datetime import datetime
|
|
from typing import Any
|
|
|
|
|
|
async def fire(*, schedule_id: str, fire_at: datetime, kind: str, actor: str | None, target_id: str, name: str,
|
|
tz: str, cron_expr: str) -> Any:
|
|
from app.scheduler import service
|
|
|
|
reason = service.TARGET_UNSUPPORTED.format(kind=service.TARGET_LABEL["source_maintenance"])
|
|
return await service.record_fire(schedule_id, fire_at, kind, "failed_to_start", reason)
|
|
|
|
|
|
async def check_target(session: Any, target_id: str) -> str | None:
|
|
return "当前版本还不能按时发起「数据源维护」这类目标"
|