aligned.worker

module documentation
(source)

Undocumented

Class StreamWorker No class docstring; 0/4 instance variable, 0/3 class variable, 0/6 method, 1/2 static method documented
Async Function monitor_process Undocumented
Async Function multi_processing Undocumented
Async Function process Undocumented
Async Function single_processing Undocumented
Function stream_job Undocumented
Variable logger Undocumented
async def monitor_process(values: list[dict], view: FeatureViewStore): (source)

Undocumented

async def multi_processing(stream_source: ReadableStream, topic_name: str, feature_views: list[FeatureViewStore]): (source)

Undocumented

async def process(stream_source: ReadableStream, topic_name: str, feature_views: list[FeatureViewStore], error_count: int = 0): (source)

Undocumented

async def single_processing(stream_source: ReadableStream, topic_name: str, feature_view: FeatureViewStore): (source)

Undocumented

def stream_job(values: list[dict], feature_view: FeatureViewStore) -> RetrievalJob: (source)

Undocumented

logger = (source)

Undocumented