kuhl_haus.mdp.exceptions package

Custom exceptions for the market data processing pipeline.

Defines exception types raised during real-time analysis and processing of WebSocket data from the Massive.com API, preserving failure context for debugging without crashing listener loops.

Submodules

kuhl_haus.mdp.exceptions.data_analysis_exception module

Custom exceptions for the market data processing pipeline.

Exceptions raised during real-time analysis of WebSocket data from Massive.com API. These wrap underlying failures to preserve context for debugging without crashing the data listener loops.

exception kuhl_haus.mdp.exceptions.data_analysis_exception.DataAnalysisException(message: str, cause: Exception = None)

Bases: Exception

Raised when Analyzer classes fail to process market data from the real-time pipeline.

Wraps exceptions during analyze_data execution, typically from malformed WebSocket payloads, unexpected Massive.com API schema changes, or downstream serialization failures before Redis cache writes. The cause attribute preserves the original exception for debugging.

Parameters:

• message – Human-readable error description.

• cause – Original exception that triggered the analysis failure.

__init__(message: str, cause: Exception = None)