+
+ Simple video transcoding pipeline. Downloads video from storage, batch triggers parallel transcoding to multiple formats and thumbnail extraction, uploads all results.
+
+
+
+```mermaid
+graph TB
+ A[processVideo] --> B[downloadFromStorage]
+ B --> C[batchTriggerAndWait]
+
+ C --> D[transcodeToHD]
+ C --> E[transcodeToSD]
+ C --> F[extractThumbnail]
+
+ D --> G[uploadToStorage]
+ E --> G
+ F --> G
+```
+
+
+
+
+
+ **Router + Coordinator pattern**. Analyzes video metadata to determine source resolution, routes to appropriate transcoding preset, batch triggers parallel post-processing for thumbnails, preview clips, and chapter detection.
+
+
+
+```mermaid
+graph TB
+ A[processVideoUpload] --> B[analyzeMetadata]
+ B --> C{Source
Resolution?}
+
+ C -->|4K Source| D[transcode4K]
+ C -->|HD Source| E[transcodeHD]
+ C -->|SD Source| F[transcodeSD]
+
+ D --> G[coordinatePostProcessing]
+ E --> G
+ F --> G
+
+ G --> H[batchTriggerAndWait]
+ H --> I[extractThumbnails]
+ H --> J[generatePreview]
+ H --> K[detectChapters]
+
+ I --> L[uploadToStorage]
+ J --> L
+ K --> L
+
+ L --> M[notifyComplete]
+```
+
+
+
+
+
+ **Router + Coordinator pattern**. Analyzes image content to detect type, routes to specialized processing (background removal for products, face detection for portraits, scene analysis for landscapes), upscales with AI, batch triggers parallel variant generation.
+
+
+
+```mermaid
+graph TB
+ A[processImageUpload] --> B[analyzeContent]
+ B --> C{Content
Type?}
+
+ C -->|Product| D[removeBackground]
+ C -->|Portrait| E[detectFaces]
+ C -->|Landscape| F[analyzeScene]
+
+ D --> G[upscaleWithAI]
+ E --> G
+ F --> G
+
+ G --> H[batchTriggerAndWait]
+ H --> I[generateWebP]
+ H --> J[generateThumbnails]
+ H --> K[generateSocialCrops]
+
+ I --> L[uploadToStorage]
+ J --> L
+ K --> L
+```
+
+
+
+
+
+ **Coordinator pattern**. Pre-processes raw audio with noise reduction and speaker diarization, batch triggers parallel tasks for transcription (Deepgram), audio enhancement, and chapter detection, aggregates results to generate show notes and publish.
+
+
+
+```mermaid
+graph TB
+ A[processAudioUpload] --> B[cleanAudio]
+ B --> C[coordinateProcessing]
+
+ C --> D[batchTriggerAndWait]
+ D --> E[transcribeWithDeepgram]
+ D --> F[enhanceAudio]
+ D --> G[detectChapters]
+
+ E --> H[generateShowNotes]
+ F --> H
+ G --> H
+
+ H --> I[publishToPlatforms]
+```
+
+
+
+
+
+ **Router pattern with human-in-the-loop**. Detects file type and routes to appropriate processor, classifies document with AI to determine type (invoice/contract/receipt), extracts structured data fields, optionally pauses with wait.forToken for human approval.
+
+
+
+```mermaid
+graph TB
+ A[processDocumentUpload] --> B[detectFileType]
+
+ B -->|PDF| C[extractText]
+ B -->|Word/Excel| D[convertToPDF]
+ B -->|Image| E[runOCR]
+
+ C --> F[classifyDocument]
+ D --> F
+ E --> F
+
+ F -->|Invoice| G[extractLineItems]
+ F -->|Contract| H[extractClauses]
+ F -->|Receipt| I[extractExpenses]
+
+ G --> J{Needs
Review?}
+ H --> J
+ I --> J
+
+ J -->|Yes| K[wait.forToken approval]
+ J -->|No| L[processAndIntegrate]
+ K --> L
+```
+
+
+
+
+
+