corvix.hydration.engine

Hydration engine — thin wrapper around PipelineEngine.

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

Classes

HydrationRunResult

Result of hydrating one poll cycle.

HydrationEngine

Runs hydration providers over notifications.

Module Contents

class corvix.hydration.engine.HydrationRunResult[source][source]

Result of hydrating one poll cycle.

notifications: list[corvix.domain.Notification] = [][source][source]
errors: list[str] = [][source][source]
class corvix.hydration.engine.HydrationEngine[source][source]

Runs hydration providers over notifications.

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

providers: list[corvix.hydration.base.HydrationProvider][source][source]
max_requests_per_cycle: int = 25[source][source]
run(notifications: list[corvix.domain.Notification], client: corvix.pipeline.base.JsonFetchClient, clients_by_account: dict[str, corvix.pipeline.base.JsonFetchClient] | None = None) → HydrationRunResult[source][source]