(trigger: AgentTrigger, now: datetime)
| 38 | |
| 39 | |
| 40 | async def enqueue_due_trigger(trigger: AgentTrigger, now: datetime) -> None: |
| 41 | async with async_session() as db: |
| 42 | await enqueue_trigger_execution( |
| 43 | db, |
| 44 | trigger=trigger, |
| 45 | source=trigger.type, |
| 46 | idempotency_key=build_scheduled_execution_key(trigger, now), |
| 47 | payload_obj=runtime_execution_payload(trigger), |
| 48 | ) |
| 49 | |
| 50 | |
| 51 | async def claim_ready_trigger_invocations(now: datetime) -> tuple[dict[uuid.UUID, list[AgentTrigger]], set[uuid.UUID]]: |
no test coverage detected