corvix.enrichment.engine

Enrichment engine — thin wrapper around PipelineEngine.

Kept for backward compatibility; new code should use corvix.pipeline.engine.PipelineEngine directly.

Classes

EnrichmentRunResult

Result of enriching one poll cycle.

EnrichmentEngine

Runs configured enrichment providers over notifications.

Module Contents

class corvix.enrichment.engine.EnrichmentRunResult[source][source]

Result of enriching one poll cycle.

contexts_by_notification_key: dict[str, dict[str, object]][source][source]
errors: list[str] = [][source][source]
property contexts_by_thread_id: dict[str, dict[str, object]][source][source]

Backward-compatible thread-keyed view of contexts.

class corvix.enrichment.engine.EnrichmentEngine[source][source]

Runs configured enrichment providers over notifications.

Deprecated since version Prefer: corvix.pipeline.engine.PipelineEngine directly. This class is a thin wrapper maintained for backward compatibility.

config: corvix.config.EnrichmentConfig[source][source]
providers: list[corvix.enrichment.base.EnrichmentProvider][source][source]
run(notifications: list[corvix.domain.Notification], client: corvix.pipeline.base.JsonFetchClient, clients_by_account: dict[str, corvix.pipeline.base.JsonFetchClient] | None = None) → EnrichmentRunResult[source][source]

Run enabled providers for all notifications in one cycle.