LLM 에이전트를 위한 분산 작업 프레임워크 'Shadows' 공개: Cron과 Heartbeat 방식의 한계 극복

async def sync_document_queue(
    perpetual: Perpetual = Perpetual(every=timedelta(minutes=2))
) -> None:
    pending = await fetch_pending_documents()
    for doc in pending:
        await shadows.add(process_document)(doc.id)

async def ingest_document(
    doc_id: str, 
    team_id: str, 
    concurrency: ConcurrencyLimit = ConcurrencyLimit("team_id", max_concurrent=5)
) -> None:
    await process_and_embed(doc_id)

await shadows.strike(ingest_document, "team_id", "==", "sales-team-3")
// ...수정 후
await shadows.restore(ingest_document, "team_id", "==", "sales-team-3")