Production-grade ingestion with orchestration
Jun 25, 2026Sanjay Sanghavi

Summary
This post details the implementation of production-grade orchestration for Forge Teamwork Graph Connectors. It introduces the `graph:connector` orchestration block, `scheduleOrUpdateTask` for root tasks, and `scheduleChildTask` for hierarchical data processing. Key contributions include the `taskRunner` function for dispatching and executing tasks, explicit failure classification (e.g., `UNAUTHORIZED`, `RATE_LIMITED`, `RETRYABLE_ERROR`), and the use of `persistentTaskMetadata` and KVS for state management. It also outlines best practices for idempotency, task granularity, and status reporting, and references SDK methods for scheduling and status updates.