Cyril Dupland
Add post-processing pipeline for carbon impact, pricing, and equivalences. Introduce orchestrator and context management for enhanced metadata handling in agent service.
5227b54 | """Registry for building the post-processing orchestrator.""" | |
| from config import settings | |
| from .base import PostProcessingOrchestrator | |
| from .processors.carbon_impact import CarbonImpactProcessor | |
| from .processors.pricing import PricingProcessor | |
| from .processors.equivalences import EquivalencesProcessor | |
| ALL = { | |
| "carbon_impact": CarbonImpactProcessor(), | |
| "pricing": PricingProcessor(), | |
| "equivalences": EquivalencesProcessor(), | |
| } | |
| def build_orchestrator() -> PostProcessingOrchestrator: | |
| enabled = getattr(settings, "postprocessors_enabled", [ | |
| "carbon_impact", | |
| "pricing", | |
| "equivalences", | |
| ]) | |
| processors = [ALL[name] for name in enabled if name in ALL] | |
| return PostProcessingOrchestrator(processors) | |