Commit 1d1b45b
authored
feat!: signal-driven conditional pipeline with single full/smoke config (#4)
* feat: conditional step execution with URL classification and fallback routing
Add classify-url pipeline step, runIf/skipIf gates, and fallback load-source routing.
- src/contracts/pipeline/condition.ts — recursive Condition type (string leaf, all/any/not combinators)
- src/core/pipeline/conditions.ts — evaluateCondition, resolveStepGate, isTruthySignal
- src/core/pipeline/compiled.ts — runIf/skipIf on CompiledPipelineStep
- src/core/pipeline/orchestrator.ts — gate evaluation before step execution
- src/builtins/pipeline-steps/classify-url/ — config, step, and descriptor
- src/config/yaml/yaml-config.ts — conditionSchema with diagnostic-name validation
- src/engine/engine-config.ts — runIf/skipIf on EngineStepConfig
- src/shared/diagnostic-names.ts — isDiagnosticName helper
- config/llm-context-loader.yaml — clean-combined rewired with classify → docling (runIf:binary_doc) → firecrawl (fallback) → clean (skipIf:code_host)
- docs: ARCHITECTURE.md, CUSTOMIZATION.md, ROADMAP.md updated
- 69 new focused tests; 388 total passing
* feat: compile-time step disable, full/smoke pipeline split, env cleanup
* feat(docling): opaque passthrough options with JSON-string coercion and standalone docs
* feat(firecrawl): opaque passthrough options with PDF sniffing
---------
Co-authored-by: David Soušek <15769039+sousekd@users.noreply.github.com>1 parent 5d409e9 commit 1d1b45b
43 files changed
Lines changed: 1704 additions & 393 deletions
File tree
- config
- docs
- agents
- src
- builtins
- llm-providers/openai-chat
- pipeline-steps/classify-url
- source-providers
- docling
- firecrawl
- bundles
- config/yaml
- contracts/pipeline
- core/pipeline
- engine
- internal/builders
- tests
- app
- builtins
- llm-providers/openai-chat
- pipeline-steps/classify-url
- source-providers
- docling
- firecrawl
- config/yaml
- core/pipeline
- engine
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
22 | 22 | | |
23 | 23 | | |
24 | 24 | | |
25 | | - | |
26 | | - | |
| 25 | + | |
| 26 | + | |
27 | 27 | | |
28 | 28 | | |
29 | 29 | | |
| |||
44 | 44 | | |
45 | 45 | | |
46 | 46 | | |
47 | | - | |
48 | | - | |
| 47 | + | |
| 48 | + | |
49 | 49 | | |
50 | | - | |
| 50 | + | |
51 | 51 | | |
52 | 52 | | |
53 | 53 | | |
54 | 54 | | |
55 | 55 | | |
56 | | - | |
57 | | - | |
| 56 | + | |
| 57 | + | |
58 | 58 | | |
59 | | - | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
60 | 63 | | |
61 | 64 | | |
62 | 65 | | |
63 | 66 | | |
64 | 67 | | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
65 | 71 | | |
66 | 72 | | |
67 | 73 | | |
68 | 74 | | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
69 | 78 | | |
70 | 79 | | |
71 | 80 | | |
| |||
76 | 85 | | |
77 | 86 | | |
78 | 87 | | |
79 | | - | |
| 88 | + | |
| 89 | + | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
80 | 95 | | |
81 | 96 | | |
82 | 97 | | |
| |||
95 | 110 | | |
96 | 111 | | |
97 | 112 | | |
98 | | - | |
99 | | - | |
| 113 | + | |
| 114 | + | |
| 115 | + | |
| 116 | + | |
| 117 | + | |
| 118 | + | |
| 119 | + | |
| 120 | + | |
100 | 121 | | |
101 | 122 | | |
102 | | - | |
| 123 | + | |
103 | 124 | | |
104 | 125 | | |
105 | | - | |
| 126 | + | |
106 | 127 | | |
107 | 128 | | |
108 | | - | |
| 129 | + | |
109 | 130 | | |
110 | 131 | | |
111 | 132 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
11 | 11 | | |
12 | 12 | | |
13 | 13 | | |
14 | | - | |
| 14 | + | |
15 | 15 | | |
16 | 16 | | |
17 | 17 | | |
| |||
64 | 64 | | |
65 | 65 | | |
66 | 66 | | |
67 | | - | |
| 67 | + | |
68 | 68 | | |
69 | 69 | | |
70 | 70 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
11 | 11 | | |
12 | 12 | | |
13 | 13 | | |
14 | | - | |
| 14 | + | |
15 | 15 | | |
16 | 16 | | |
17 | 17 | | |
| |||
21 | 21 | | |
22 | 22 | | |
23 | 23 | | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
24 | 31 | | |
25 | | - | |
26 | 32 | | |
27 | 33 | | |
28 | | - | |
| 34 | + | |
29 | 35 | | |
30 | 36 | | |
| 37 | + | |
31 | 38 | | |
32 | 39 | | |
33 | 40 | | |
| |||
44 | 51 | | |
45 | 52 | | |
46 | 53 | | |
47 | | - | |
48 | | - | |
49 | | - | |
50 | | - | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
51 | 60 | | |
52 | 61 | | |
53 | 62 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
11 | 11 | | |
12 | 12 | | |
13 | 13 | | |
14 | | - | |
| 14 | + | |
15 | 15 | | |
16 | 16 | | |
17 | 17 | | |
| |||
21 | 21 | | |
22 | 22 | | |
23 | 23 | | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
24 | 31 | | |
25 | | - | |
26 | 32 | | |
27 | 33 | | |
28 | | - | |
| 34 | + | |
29 | 35 | | |
30 | 36 | | |
| 37 | + | |
31 | 38 | | |
32 | 39 | | |
33 | 40 | | |
| |||
44 | 51 | | |
45 | 52 | | |
46 | 53 | | |
47 | | - | |
48 | | - | |
49 | | - | |
50 | | - | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
51 | 60 | | |
52 | 61 | | |
53 | 62 | | |
| |||
0 commit comments