orchestrata_ultimate.orchestrator

Reference › orchestrata_ultimate › orchestrator

Orchestrator (U:Ox) - Governance and policy management engine

The orchestrator package is the Orchestrator volk (U:Ox): it parses intents, manages facts and decides what is allowed. Concierge is where a human intent enters; from there the package turns that intent into work for the volks, guarded by Prolog governance rules and recorded in Redis and the knowledge graph. The package narrative tells the story with diagrams; this page groups the module pages.

Intent pipeline. intent_broker is the front door and intent_broker_factory wires it. Free text goes through intent_normalizer, intent_classifier, intent_vocabulary and nlp; typed strings go through intent_parser and parameter_extractor. Each intent is then checked by intent_security and intent_validator, analysed by the impact subpackage, routed and dispatched by intent_router. Shared types are in intent_types, intent_enums and intent_results; state and telemetry in intent_lifecycle, intent_history, intent_metrics; reuse in intent_template, intent_workflow and ambiguity_resolver.

Pipeline execution. pipeline_router plans stages per work type, pipeline_runner runs them through Postman, with pipeline_escalation, verification_gate and artifact_store; pipeline_kernel bridges the gateway.

Governance and facts. engine evaluates policy over Prolog through prolog_worker; policy_registry versions policies; graph_audit records decisions; fact_manager, fact_store and fact_graph manage facts; orchestrator is the staffing facade.

Entry points are IntentBroker.process_text and process_intent, PipelineRunner.run, PipelineKernelClient.send_packet and UOxEngine.evaluate_policy. Start with intent_broker, then pipeline_runner and engine.

Curated narrative

The hand-written story of this package: orchestrata_ultimate.orchestrator.

42 modules, 15,904 lines of code.

Subpackages

Package Modules LOC
impact 7 1,398

Modules

Module Summary LOC
__init__ Orchestrator (U:Ox) - Governance and policy management engine 25
ambiguity_resolver Ambiguity detection and resolution for intents. 261
artifact_store Orchestrator-side re-export of the canonical artifact store + ArtifactType enum. 47
engine U:Ox governance engine with Prolog-based policy evaluation. 751
fact_graph Graph operations for the fact store. 213
fact_manager Fact lifecycle management for Orchestrata. 485
fact_store Real fact storage using Redis and the graph. 267
graph_audit Graph audit trail for Orchestrata. 674
intent_broker Intent Broker — core orchestrator for the intent pipeline. 475
intent_broker_factory Production factory for the SPEC-003 Intent Broker pipeline. 126
intent_classifier Extensible NL intent classifier + workflow mapper + evaluator. 690
intent_enums Intent validation outcome enums. 21
intent_history Intent history with dual Redis+graph storage. 424
intent_lifecycle Intent lifecycle state machine. 250
intent_metrics Intent Metrics and Monitoring System. 673
intent_normalizer Haiku normalization stage — clean the sentence BEFORE Prolog sees it. 336
intent_parser Intent parsing for Orchestrata. 378
intent_results Intent Broker result types. 137
intent_router Intent routing and CXP dispatch. 372
intent_security Intent security: authentication, authorization, injection prevention, rate limiting. 376
intent_template Intent template system for reusable intent patterns. 319
intent_types Intent Broker type system. 375
intent_validator Prolog-based intent validation. 306
intent_vocabulary Extensible NL intent vocabulary — keyword → category registries. 573
intent_workflow Intent workflow engine for multi-step intent execution. 494
nlp NLP processing for intent parsing. 604
orchestrator Orchestrator (U:Ox) - Governance and policy management engine 210
parameter_extractor Advanced parameter extraction from natural language. 286
pipeline_escalation PipelineRunner escalation INTERRUPT mixin (W3.1 absorption, final piece). 533
pipeline_kernel Pipeline Kernel Client — bridges Gateway → PipelineRunner. 584
pipeline_router Pipeline router — maps work types to agent stage sequences. 367
pipeline_runner PipelineRunner — executes dynamic agent stages through Postman routing. 1371
policy_registry Policy registry for governance and compliance. 408
prolog_worker Janus-swi Prolog worker for thread-safe, PARALLEL governance queries. 339
verification_gate PipelineVerificationGate — production wiring for the verification subsystem. 756

Dependency diagram

Package dependency diagram orchestrata_ultimate.orchestrator

Truncated: showing 36 of 36 modules/subpackages (most connected first) and 10 of 13 outside packages.