{ "type": "excalidraw", "version": 2, "source": "https://excalidraw.com", "appState": { "viewBackgroundColor": "#ffffff", "gridSize": 20 }, "files": {}, "elements": [ { "type": "text", "id": "title", "x": 60, "y": 36, "width": 1300, "height": 35, "text": "Zoom 3: pz run - dispatch, one event stream, retries", "originalText": "Zoom 3: pz run - dispatch, one event stream, retries", "fontSize": 28, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#1e40af", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500001, "version": 1, "versionNonce": 1, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "text", "id": "subtitle", "x": 60, "y": 80, "width": 1100, "height": 20, "text": "hello-pz executing with engine.threads: 2 - row counts are the sample's real data", "originalText": "hello-pz executing with engine.threads: 2 - row counts are the sample's real data", "fontSize": 15, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#64748b", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500002, "version": 1, "versionNonce": 2, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "text", "id": "sched_label", "x": 60, "y": 122, "width": 700, "height": 18, "text": "1. THE DISPATCHER - topological, engine.threads = 2", "originalText": "1. THE DISPATCHER - topological, engine.threads = 2", "fontSize": 14, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#3b82f6", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500003, "version": 1, "versionNonce": 3, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "text", "id": "lane1_lbl", "x": 60, "y": 176, "width": 80, "height": 14, "text": "slot 1", "originalText": "slot 1", "fontSize": 11, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#64748b", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500004, "version": 1, "versionNonce": 4, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "text", "id": "lane2_lbl", "x": 60, "y": 236, "width": 80, "height": 14, "text": "slot 2", "originalText": "slot 2", "fontSize": 11, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#64748b", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500005, "version": 1, "versionNonce": 5, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "rectangle", "id": "g_b1", "x": 150, "y": 164, "width": 140, "height": 38, "strokeColor": "#c2410c", "backgroundColor": "#fed7aa", "fillStyle": "solid", "strokeWidth": 2, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500006, "version": 1, "versionNonce": 6, "isDeleted": false, "groupIds": [], "boundElements": [ { "id": "g_b1_t", "type": "text" } ], "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "g_b1_t", "x": 158, "y": 176, "width": 124, "height": 14, "text": "crm.orders", "originalText": "crm.orders", "fontSize": 11, "fontFamily": 3, "textAlign": "center", "verticalAlign": "middle", "strokeColor": "#374151", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500007, "version": 1, "versionNonce": 7, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": "g_b1", "lineHeight": 1.25 }, { "type": "rectangle", "id": "g_b2", "x": 300, "y": 164, "width": 100, "height": 38, "strokeColor": "#1e3a5f", "backgroundColor": "#3b82f6", "fillStyle": "solid", "strokeWidth": 2, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500008, "version": 1, "versionNonce": 8, "isDeleted": false, "groupIds": [], "boundElements": [ { "id": "g_b2_t", "type": "text" } ], "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "g_b2_t", "x": 308, "y": 176, "width": 84, "height": 14, "text": "stg_orders", "originalText": "stg_orders", "fontSize": 11, "fontFamily": 3, "textAlign": "center", "verticalAlign": "middle", "strokeColor": "#ffffff", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500009, "version": 1, "versionNonce": 9, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": "g_b2", "lineHeight": 1.25 }, { "type": "rectangle", "id": "g_b3", "x": 410, "y": 164, "width": 150, "height": 38, "strokeColor": "#1e3a5f", "backgroundColor": "#3b82f6", "fillStyle": "solid", "strokeWidth": 2, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500010, "version": 1, "versionNonce": 10, "isDeleted": false, "groupIds": [], "boundElements": [ { "id": "g_b3_t", "type": "text" } ], "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "g_b3_t", "x": 418, "y": 176, "width": 134, "height": 14, "text": "orders_enriched", "originalText": "orders_enriched", "fontSize": 11, "fontFamily": 3, "textAlign": "center", "verticalAlign": "middle", "strokeColor": "#ffffff", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500011, "version": 1, "versionNonce": 11, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": "g_b3", "lineHeight": 1.25 }, { "type": "rectangle", "id": "g_b4", "x": 570, "y": 164, "width": 110, "height": 38, "strokeColor": "#b45309", "backgroundColor": "#fef3c7", "fillStyle": "solid", "strokeWidth": 2, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500012, "version": 1, "versionNonce": 12, "isDeleted": false, "groupIds": [], "boundElements": [ { "id": "g_b4_t", "type": "text" } ], "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "g_b4_t", "x": 578, "y": 176, "width": 94, "height": 14, "text": "checks (x2)", "originalText": "checks (x2)", "fontSize": 11, "fontFamily": 3, "textAlign": "center", "verticalAlign": "middle", "strokeColor": "#374151", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500013, "version": 1, "versionNonce": 13, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": "g_b4", "lineHeight": 1.25 }, { "type": "rectangle", "id": "g_b5", "x": 690, "y": 164, "width": 170, "height": 38, "strokeColor": "#047857", "backgroundColor": "#a7f3d0", "fillStyle": "solid", "strokeWidth": 2, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500014, "version": 1, "versionNonce": 14, "isDeleted": false, "groupIds": [], "boundElements": [ { "id": "g_b5_t", "type": "text" } ], "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "g_b5_t", "x": 698, "y": 176, "width": 154, "height": 14, "text": "lake.orders_curated", "originalText": "lake.orders_curated", "fontSize": 11, "fontFamily": 3, "textAlign": "center", "verticalAlign": "middle", "strokeColor": "#374151", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500015, "version": 1, "versionNonce": 15, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": "g_b5", "lineHeight": 1.25 }, { "type": "rectangle", "id": "g_c1", "x": 150, "y": 224, "width": 130, "height": 38, "strokeColor": "#c2410c", "backgroundColor": "#fed7aa", "fillStyle": "solid", "strokeWidth": 2, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500016, "version": 1, "versionNonce": 16, "isDeleted": false, "groupIds": [], "boundElements": [ { "id": "g_c1_t", "type": "text" } ], "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "g_c1_t", "x": 158, "y": 236, "width": 114, "height": 14, "text": "crm.customers", "originalText": "crm.customers", "fontSize": 11, "fontFamily": 3, "textAlign": "center", "verticalAlign": "middle", "strokeColor": "#374151", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500017, "version": 1, "versionNonce": 17, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": "g_c1", "lineHeight": 1.25 }, { "type": "text", "id": "g_idle", "x": 292, "y": 238, "width": 110, "height": 14, "text": "(idle - waiting)", "originalText": "(idle - waiting)", "fontSize": 10, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#94a3b8", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500018, "version": 1, "versionNonce": 18, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "rectangle", "id": "g_c2", "x": 410, "y": 224, "width": 120, "height": 38, "strokeColor": "#1e3a5f", "backgroundColor": "#3b82f6", "fillStyle": "solid", "strokeWidth": 2, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500019, "version": 1, "versionNonce": 19, "isDeleted": false, "groupIds": [], "boundElements": [ { "id": "g_c2_t", "type": "text" } ], "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "g_c2_t", "x": 418, "y": 236, "width": 104, "height": 14, "text": "order_totals", "originalText": "order_totals", "fontSize": 11, "fontFamily": 3, "textAlign": "center", "verticalAlign": "middle", "strokeColor": "#ffffff", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500020, "version": 1, "versionNonce": 20, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": "g_c2", "lineHeight": 1.25 }, { "type": "rectangle", "id": "g_c3", "x": 540, "y": 224, "width": 160, "height": 38, "strokeColor": "#047857", "backgroundColor": "#a7f3d0", "fillStyle": "solid", "strokeWidth": 2, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500021, "version": 1, "versionNonce": 21, "isDeleted": false, "groupIds": [], "boundElements": [ { "id": "g_c3_t", "type": "text" } ], "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "g_c3_t", "x": 548, "y": 236, "width": 144, "height": 14, "text": "lake.order_totals", "originalText": "lake.order_totals", "fontSize": 11, "fontFamily": 3, "textAlign": "center", "verticalAlign": "middle", "strokeColor": "#374151", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500022, "version": 1, "versionNonce": 22, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": "g_c3", "lineHeight": 1.25 }, { "type": "line", "id": "g_axis", "x": 150, "y": 278, "width": 710, "height": 0, "strokeColor": "#94a3b8", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500023, "version": 1, "versionNonce": 23, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "points": [ [ 0, 0 ], [ 710, 0 ] ] }, { "type": "text", "id": "g_axis_lbl", "x": 150, "y": 284, "width": 500, "height": 13, "text": "time -> (bars colored by node kind: SourceLoad / Pipeline / Check / SinkWrite)", "originalText": "time -> (bars colored by node kind: SourceLoad / Pipeline / Check / SinkWrite)", "fontSize": 10, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#94a3b8", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500024, "version": 1, "versionNonce": 24, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "text", "id": "sched_note", "x": 60, "y": 312, "width": 800, "height": 30, "text": "a node becomes runnable when all parents succeed. I/O nodes overlap CPU nodes naturally:\nDuckDB queries run on DuckDB's own threads while .NET async handles the edges.", "originalText": "a node becomes runnable when all parents succeed. I/O nodes overlap CPU nodes naturally:\nDuckDB queries run on DuckDB's own threads while .NET async handles the edges.", "fontSize": 11, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#64748b", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 500025, "version": 1, "versionNonce": 25, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "text", "id": "tty_label", "x": 940, "y": 122, "width": 600, "height": 18, "text": "2. WHAT YOU SEE (TTY renderer)", "originalText": "2. WHAT YOU SEE (TTY renderer)", "fontSize": 14, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#3b82f6", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 510001, "version": 1, "versionNonce": 31, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "rectangle", "id": "tty_box", "x": 940, "y": 148, "width": 620, "height": 196, "strokeColor": "#1e293b", "backgroundColor": "#1e293b", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 510002, "version": 1, "versionNonce": 32, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "tty_code", "x": 954, "y": 160, "width": 595, "height": 173, "text": "Running hello_pz (run 01JZX9M2E8...)\n sources\n + crm.customers 3 rows 0.1s (native scan: read_csv)\n + crm.orders 5 rows 0.1s (native scan: read_csv)\n pipelines\n + stg_orders 3 rows 0.2s\n ~ orders_enriched 61% hash join\n sinks\n o lake.order_totals queued\nSummary: 6 of 9 done - peak mem 0.2 GB (duckdb) + 90 MB (host)", "originalText": "Running hello_pz (run 01JZX9M2E8...)\n sources\n + crm.customers 3 rows 0.1s (native scan: read_csv)\n + crm.orders 5 rows 0.1s (native scan: read_csv)\n pipelines\n + stg_orders 3 rows 0.2s\n ~ orders_enriched 61% hash join\n sinks\n o lake.order_totals queued\nSummary: 6 of 9 done - peak mem 0.2 GB (duckdb) + 90 MB (host)", "fontSize": 11, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#e2e8f0", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 510003, "version": 1, "versionNonce": 33, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "text", "id": "nd_label", "x": 60, "y": 372, "width": 800, "height": 18, "text": "3. THE SAME RUN, AS A MACHINE SEES IT (--log-format json)", "originalText": "3. THE SAME RUN, AS A MACHINE SEES IT (--log-format json)", "fontSize": 14, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#3b82f6", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 520001, "version": 1, "versionNonce": 41, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "rectangle", "id": "nd_box", "x": 60, "y": 398, "width": 1030, "height": 132, "strokeColor": "#1e293b", "backgroundColor": "#1e293b", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 520002, "version": 1, "versionNonce": 42, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "nd_code", "x": 74, "y": 409, "width": 1005, "height": 110, "text": "{\"event\":\"run_started\",\"at\":\"2026-07-09T09:14:03.120Z\",\"runId\":\"01JZX9M2E8...\",\"projectName\":\"hello_pz\",\"nodeCount\":9}\n{\"event\":\"node_started\",\"nodeId\":\"c9a41f...\",\"kind\":\"SourceLoad\",\"name\":\"crm.orders\"}\n{\"event\":\"node_progress\",\"name\":\"crm.orders\",\"rows\":5,\"bytes\":183,\"batches\":1}\n{\"event\":\"node_completed\",\"name\":\"crm.orders\",\"kind\":\"SourceLoad\",\"status\":\"success\",\"rows\":5,\"durationMs\":104}\n{\"event\":\"retry_scheduled\",\"name\":\"crm.orders\",\"attempt\":2,\"maxAttempts\":3,\"delayMs\":800,\"reason\":\"transient: reset\"}\n{\"event\":\"node_started\",\"nodeId\":\"7be2d0...\",\"kind\":\"Pipeline\",\"name\":\"stg_orders\"}\n...\n{\"event\":\"run_completed\",\"status\":\"success\",\"durationMs\":1240}", "originalText": "{\"event\":\"run_started\",\"at\":\"2026-07-09T09:14:03.120Z\",\"runId\":\"01JZX9M2E8...\",\"projectName\":\"hello_pz\",\"nodeCount\":9}\n{\"event\":\"node_started\",\"nodeId\":\"c9a41f...\",\"kind\":\"SourceLoad\",\"name\":\"crm.orders\"}\n{\"event\":\"node_progress\",\"name\":\"crm.orders\",\"rows\":5,\"bytes\":183,\"batches\":1}\n{\"event\":\"node_completed\",\"name\":\"crm.orders\",\"kind\":\"SourceLoad\",\"status\":\"success\",\"rows\":5,\"durationMs\":104}\n{\"event\":\"retry_scheduled\",\"name\":\"crm.orders\",\"attempt\":2,\"maxAttempts\":3,\"delayMs\":800,\"reason\":\"transient: reset\"}\n{\"event\":\"node_started\",\"nodeId\":\"7be2d0...\",\"kind\":\"Pipeline\",\"name\":\"stg_orders\"}\n...\n{\"event\":\"run_completed\",\"status\":\"success\",\"durationMs\":1240}", "fontSize": 10, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#22c55e", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 520003, "version": 1, "versionNonce": 43, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "text", "id": "nd_note", "x": 1120, "y": 398, "width": 460, "height": 140, "text": "one typed event stream, two renderers:\nthe TTY tree above and this NDJSON are\nthe same events (contract: docs/events.md)\n\nper node, order is guaranteed:\nnode_started -> node_progress* ->\nretry_scheduled* -> node_completed\n\nfields are append-only - renaming or\nremoving one is a breaking change", "originalText": "one typed event stream, two renderers:\nthe TTY tree above and this NDJSON are\nthe same events (contract: docs/events.md)\n\nper node, order is guaranteed:\nnode_started -> node_progress* ->\nretry_scheduled* -> node_completed\n\nfields are append-only - renaming or\nremoving one is a breaking change", "fontSize": 11, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#64748b", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 520004, "version": 1, "versionNonce": 44, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "text", "id": "fail_label", "x": 60, "y": 586, "width": 500, "height": 18, "text": "4. WHEN A NODE FAILS", "originalText": "4. WHEN A NODE FAILS", "fontSize": 14, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#3b82f6", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530001, "version": 1, "versionNonce": 51, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "rectangle", "id": "f1", "x": 60, "y": 650, "width": 150, "height": 36, "strokeColor": "#047857", "backgroundColor": "#a7f3d0", "fillStyle": "solid", "strokeWidth": 2, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530002, "version": 1, "versionNonce": 52, "isDeleted": false, "groupIds": [], "boundElements": [ { "id": "f1t", "type": "text" } ], "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "f1t", "x": 68, "y": 661, "width": 134, "height": 14, "text": "crm.orders ok", "originalText": "crm.orders ok", "fontSize": 11, "fontFamily": 3, "textAlign": "center", "verticalAlign": "middle", "strokeColor": "#374151", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530003, "version": 1, "versionNonce": 53, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": "f1", "lineHeight": 1.25 }, { "type": "arrow", "id": "fa1", "x": 214, "y": 668, "width": 42, "height": 0, "strokeColor": "#047857", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 2, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530004, "version": 1, "versionNonce": 54, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "points": [ [ 0, 0 ], [ 42, 0 ] ], "startBinding": null, "endBinding": null, "startArrowhead": null, "endArrowhead": "arrow" }, { "type": "rectangle", "id": "f2", "x": 260, "y": 650, "width": 180, "height": 36, "strokeColor": "#b91c1c", "backgroundColor": "#fecaca", "fillStyle": "solid", "strokeWidth": 2, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530005, "version": 1, "versionNonce": 55, "isDeleted": false, "groupIds": [], "boundElements": [ { "id": "f2t", "type": "text" } ], "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "f2t", "x": 268, "y": 661, "width": 164, "height": 14, "text": "stg_orders FAILED", "originalText": "stg_orders FAILED", "fontSize": 11, "fontFamily": 3, "textAlign": "center", "verticalAlign": "middle", "strokeColor": "#b91c1c", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530006, "version": 1, "versionNonce": 56, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": "f2", "lineHeight": 1.25 }, { "type": "arrow", "id": "fa2", "x": 444, "y": 660, "width": 44, "height": 28, "strokeColor": "#b91c1c", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "dashed", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530007, "version": 1, "versionNonce": 57, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "points": [ [ 0, 0 ], [ 44, -28 ] ], "startBinding": null, "endBinding": null, "startArrowhead": null, "endArrowhead": "arrow" }, { "type": "arrow", "id": "fa3", "x": 444, "y": 676, "width": 44, "height": 28, "strokeColor": "#b91c1c", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "dashed", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530008, "version": 1, "versionNonce": 58, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "points": [ [ 0, 0 ], [ 44, 28 ] ], "startBinding": null, "endBinding": null, "startArrowhead": null, "endArrowhead": "arrow" }, { "type": "rectangle", "id": "f3", "x": 492, "y": 614, "width": 230, "height": 36, "strokeColor": "#1e40af", "backgroundColor": "#dbeafe", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "dashed", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530009, "version": 1, "versionNonce": 59, "isDeleted": false, "groupIds": [], "boundElements": [ { "id": "f3t", "type": "text" } ], "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "f3t", "x": 500, "y": 625, "width": 214, "height": 14, "text": "orders_enriched skipped", "originalText": "orders_enriched skipped", "fontSize": 11, "fontFamily": 3, "textAlign": "center", "verticalAlign": "middle", "strokeColor": "#1e40af", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530010, "version": 1, "versionNonce": 60, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": "f3", "lineHeight": 1.25 }, { "type": "rectangle", "id": "f4", "x": 492, "y": 686, "width": 230, "height": 36, "strokeColor": "#1e40af", "backgroundColor": "#dbeafe", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "dashed", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530011, "version": 1, "versionNonce": 61, "isDeleted": false, "groupIds": [], "boundElements": [ { "id": "f4t", "type": "text" } ], "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "f4t", "x": 500, "y": 697, "width": 214, "height": 14, "text": "order_totals skipped", "originalText": "order_totals skipped", "fontSize": 11, "fontFamily": 3, "textAlign": "center", "verticalAlign": "middle", "strokeColor": "#1e40af", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530012, "version": 1, "versionNonce": 62, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": "f4", "lineHeight": 1.25 }, { "type": "text", "id": "fail_note", "x": 60, "y": 742, "width": 700, "height": 30, "text": "default = dbt semantics: fail the node, skip its descendants, let independent\nbranches finish (--fail-fast cancels the world). exit code becomes 1.", "originalText": "default = dbt semantics: fail the node, skip its descendants, let independent\nbranches finish (--fail-fast cancels the world). exit code becomes 1.", "fontSize": 11, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#64748b", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530013, "version": 1, "versionNonce": 63, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "text", "id": "rr_label", "x": 820, "y": 614, "width": 640, "height": 15, "text": "run_results.json - checkpointed after every node (crash-safe)", "originalText": "run_results.json - checkpointed after every node (crash-safe)", "fontSize": 11, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#64748b", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530014, "version": 1, "versionNonce": 64, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "rectangle", "id": "rr_box", "x": 820, "y": 632, "width": 760, "height": 82, "strokeColor": "#1e293b", "backgroundColor": "#1e293b", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530015, "version": 1, "versionNonce": 65, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "rr_code", "x": 834, "y": 643, "width": 735, "height": 55, "text": "{\"runId\":\"01JZX9M2E8...\",\"nodes\":[\n {\"name\":\"stg_orders\",\"status\":\"failed\",\"error\":\"PZ0501: Binder Error: column 'amout' does not exist\"},\n {\"name\":\"orders_enriched\",\"status\":\"skipped\"}, ... ]}", "originalText": "{\"runId\":\"01JZX9M2E8...\",\"nodes\":[\n {\"name\":\"stg_orders\",\"status\":\"failed\",\"error\":\"PZ0501: Binder Error: column 'amout' does not exist\"},\n {\"name\":\"orders_enriched\",\"status\":\"skipped\"}, ... ]}", "fontSize": 10, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#22c55e", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530016, "version": 1, "versionNonce": 66, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "text", "id": "rr_note", "x": 820, "y": 728, "width": 760, "height": 45, "text": "$ pz retry re-runs only failed + skipped nodes; succeeded nodes with unchanged\nhash and upstream results are skipped. transient errors also retry in-run: the\nconnector classifies (IsTransient, RetryAfter), the engine backs off + jitters.", "originalText": "$ pz retry re-runs only failed + skipped nodes; succeeded nodes with unchanged\nhash and upstream results are skipped. transient errors also retry in-run: the\nconnector classifies (IsTransient, RetryAfter), the engine backs off + jitters.", "fontSize": 11, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#64748b", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530017, "version": 1, "versionNonce": 67, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "text", "id": "exit_codes", "x": 60, "y": 806, "width": 900, "height": 17, "text": "exit codes: 0 success | 1 completed with node failures | 2 config/validation error | 3 fatal", "originalText": "exit codes: 0 success | 1 completed with node failures | 2 config/validation error | 3 fatal", "fontSize": 13, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#1e40af", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 530018, "version": 1, "versionNonce": 68, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "text", "id": "cap_note", "x": 60, "y": 346, "width": 760, "height": 14, "text": "max_concurrency (per instance) - instance permit acquired BEFORE the global engine.threads slot", "originalText": "max_concurrency (per instance) - instance permit acquired BEFORE the global engine.threads slot", "fontSize": 10, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#b45309", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 540001, "version": 1, "versionNonce": 641001, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "text", "id": "retry_precedence_note", "x": 820, "y": 780, "width": 760, "height": 16, "text": "retry config: per source/sink instance + per dataset/output (nearest wins)", "originalText": "retry config: per source/sink instance + per dataset/output (nearest wins)", "fontSize": 11, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#b45309", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 540002, "version": 1, "versionNonce": 641002, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": null, "lineHeight": 1.25 }, { "type": "rectangle", "id": "breaker_box", "x": 820, "y": 802, "width": 760, "height": 70, "strokeColor": "#b45309", "backgroundColor": "#fef3c7", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "dashed", "roughness": 0, "opacity": 100, "angle": 0, "seed": 540003, "version": 1, "versionNonce": 641003, "isDeleted": false, "groupIds": [], "boundElements": [ { "id": "breaker_box_t", "type": "text" } ], "link": null, "locked": false, "roundness": { "type": 3 } }, { "type": "text", "id": "breaker_box_t", "x": 834, "y": 810, "width": 732, "height": 54, "text": "circuit breaker per instance: N transient failures -> open (cool-down)\n-> half-open probe -> closed. waits don't consume attempts;\ngive-up = PZ0506 (retryable) - pz retry picks it back up once recovered", "originalText": "circuit breaker per instance: N transient failures -> open (cool-down)\n-> half-open probe -> closed. waits don't consume attempts;\ngive-up = PZ0506 (retryable) - pz retry picks it back up once recovered", "fontSize": 10, "fontFamily": 3, "textAlign": "left", "verticalAlign": "top", "strokeColor": "#374151", "backgroundColor": "transparent", "fillStyle": "solid", "strokeWidth": 1, "strokeStyle": "solid", "roughness": 0, "opacity": 100, "angle": 0, "seed": 540004, "version": 1, "versionNonce": 641004, "isDeleted": false, "groupIds": [], "boundElements": null, "link": null, "locked": false, "containerId": "breaker_box", "lineHeight": 1.25 } ] }