mcp_knowledge_ops 0.4.0
mcp_knowledge_ops: ^0.4.0 copied to clipboard
Knowledge operations including pipelines, workflows, scheduling, and automated processing for curation, summarization, and pattern mining in the MCP ecosystem.
0.4.0 - 2026-11-04 - Cascade refresh reports what it did #
Breaking (behaviour of the same call) #
CascadeRefreshExecutor.executereported every node refreshed (success: true) without refreshing anything. A node is now refreshed by the executor'sNodeRefresher(CascadeRefreshExecutor(refresher:)), reported refreshed only when the refresher returned, and reported failed with the message when it throws. An executor built without a refresher reports every node failed ("No node refresher is configured; nothing was refreshed"), so a caller that relied on the empty success now seesfailedCountequal to the node count.
Added #
NodeRefreshertypedef and therefresherconstructor argument.
Changed (dependency) #
mcp_bundlefloor^0.4.14(the current release).
0.3.2 - 2026-11-01 - Event ids and the circuit breaker on the web #
Fixed #
OpsEvent.generateEventIdderived the second part of the id from the timestamp, so two ids made in the same clock tick were equal; on the web, where the clock ticks every millisecond, that is routine. The second part is now a process-wide counter, so ids stay unique; theevt_<hex>_<hex>shape is unchanged.EventCircuitBreakerwith aresetTimeoutof zero stayed open on a clock that ticks every millisecond, because the reset time was compared withisAfter. The momentresetAtnow counts as elapsed.
0.3.1 - 2026-11-01 - Step id on the dispatched action #
Added #
BehaviorAction.stepId(optional, not part of the JSON form): the behavior engine sets it on every action it hands to the dispatcher, including after a resume, so the dispatcher can tell which step it is running. An action without arguments is now passed as a copy that carries the step id instead of the same instance.
0.3.0 - 2026-10-31 - Behavior action arguments filled from the run state, unique ids #
Breaking #
Under the 0.x compatibility rule this makes the release a minor. Consumers on ^0.2.x keep the old behaviour until they raise their floor.
- The behavior engine fills
${...}in a step action's arguments from the run state before it dispatches (bundle spec 11 §11.7). It used to hand the arguments over exactly as written, so an argument that happens to contain${...}(for example a shell snippet) now changes; write\${...}to keep it literal.
Added #
- A string argument that is exactly one
${path}takes the value at that state path with its type; any other string is rendered as text; a path with no value isnullalone and nothing inside text. Maps and lists are walked at any depth, including a skill action'sinputs. A step reads an earlier step's output by its id (${fetch.score}) or by a merged key. The action given to the dispatcher is a new object; the step definition is not changed.
Changed (dependency floor) #
mcp_bundlefloor raised to^0.4.12.
Fixed #
- Ids built from the clock alone (checkpoint, trace, span, audit, run, schedule, approval request and build ids) repeated when two records were made in the same tick, and a store replaced the earlier record without an error. They now come from one process-wide generator,
<prefix><sep><microseconds><sep><sequence>; prefixes and separators are unchanged.
0.2.2 - 2026-05-30 - Behavior definition execution engine (additive) #
Added #
lib/src/behavior/— new module: unified behavior definition execution engine.BehaviorEngine— runner; takes aList<BehaviorStep>(engine-native) plus an initial state map viarun(runId, steps, state)and executes step-by-step, evaluating guards and routing outcomes. Engine-native types only — nomcp_bundledependency (hosts map their bundle section toBehaviorStep).BehaviorRunnable— per-activation handle returned byBehaviorEngine.run; supportsresume(runId, {statePatch})for suspended runs (the optionalstatePatchis merged into the run state before re-evaluating the waiting guard — e.g.{approved: true}unblocks an approval gate).BehaviorStep— runtime step record (id, status, result, error).Guard— evaluates a step'swhenexpression againstStateStoreentries; returns the outcome key used forthenrouting.Outcome— registry of named outcomes (proceed,skip,wait,stop,goto:<id>) plus host-registered custom outcomes.StateStore— abstract key/value store interface with two concrete implementations:EphemeralStateStore(in-memory, per-run) andKvStateStore(durable, backed by aKvPortfor suspend/resume across restarts).
OpsRuntime.behaviorRegistry—Map<String, BehaviorRunnable Function()>field (default empty map, additive). Hosts (brain_kernelBundleActivation) populate this map at bundle activation time;bk.behavior.*tools dispatch through it.- Barrel export of the behavior module added to
lib/mcp_knowledge_ops.dart. - 17 new regression tests. Total: 1081 PASS.
Backward compatibility #
- Fully additive.
OpsRuntime.fromConsumedPortsdefault forbehaviorRegistryisconst {}. No existing field, adapter, or execution path changed.^0.2.1caret consumers resolve0.2.2automatically.
0.2.1 - 2026-05-23 - mcp_bundle 0.4.0 cascade #
Changed (cascade) #
mcp_bundlecaret bumped from^0.3.0to^0.4.0. mcp_knowledge_ops does not touchUiSection.pagesdirectly, so this release is a caret-only cascade. Consumers should bump to^0.2.1.
0.2.0 - 2026-04-28 - Stateless Orchestration & New Pipelines #
Added #
- Central
ExecutionEnginecoordinating pipeline and workflow runs. - New built-in pipelines — ingest, summary refresh, index rebuild, cascade refresh, clustering — alongside existing curation and pattern mining.
- Workflow subsystem — review models, approval routing, cancellation.
- Scheduler — MCP tools integration, scheduler events.
- Runbooks subsystem.
- Observability layer — events, errors, structured logging / metrics / tracing.
- Standard port adapters implementing
mcp_bundleops Contract Layer.
Changed #
- Persistence delegated to
mcp_fact_graph;mcp_knowledge_opsis now a stateless orchestration layer. - Pipeline / workflow infrastructure restructured around the new execution engine.
- New dependency:
mcp_bundle ^0.3.0.
Removed #
- Document, embedding, extraction, index, retrieval, search subsystems — now owned by
mcp_fact_graphor replaced by Contract Layer ports. - Standalone summarization pipeline (replaced by summary refresh pipeline).
0.1.1 Bugfix #
Fixed #
- Removed duplicate OpsLlmPort, OpsLlmRequest, LlmCompletion definitions
- Unified LLM Port types to use mcp_bundle Contract Layer exclusively
- Updated pipeline classes to use LlmPort instead of OpsLlmPort
- Fixed documentation examples to use correct LlmResponse.content field
0.1.0 Initial Release #
Added #
Core Features
-
Pipeline System
Pipelinemodel with sequential stagesPipelineStagefor individual processing stepsPipelineExecutorfor pipeline executionPipelineResultwith metrics and output- Checkpoint support for state persistence
- Retry policies for error recovery
-
Workflow System
Workflowmodel for complex orchestrationWorkflowActionfor discrete stepsWorkflowExecutorfor workflow execution- Conditional branching support
- Variable scoping and passing
- Event-driven execution
-
Scheduling System
Schedulerfor automated job executionScheduledJobfor job definitionsCronSchedulefor cron-like expressions- Concurrent job limiting
- Timezone support
-
Built-in Operations
CurationPipelinefor candidate curationSummarizationPipelinefor summary generationPatternMiningPipelinefor pattern discovery- Configurable thresholds and parameters
-
Port-Based Architecture
OpsPortfor operation executionFactGraphPortfor fact graph accessLlmPortfor LLM integration
Pipeline Features #
- Sequential stage execution
- Checkpoint save/restore
- Metrics collection
- Error handling and retry
- Timeout management
Workflow Features #
- Action sequencing
- Conditional branching
- Variable interpolation
- Parallel execution
- Error recovery
Scheduling Features #
- Cron expression support
- One-time and recurring jobs
- Job dependencies
- Execution history
Data Models #
Pipeline- Pipeline definitionPipelineStage- Pipeline stagePipelineResult- Execution resultPipelineContext- Execution contextWorkflow- Workflow definitionWorkflowAction- Workflow actionWorkflowExecution- Execution stateScheduledJob- Job definitionCurationInput/Output- Curation I/OSummarizationInput/Output- Summarization I/OPatternMiningInput/Output- Pattern mining I/O