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
Variable process_time Undocumented
Variable processed_rows_count 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) -> RetrivalJob: (source)

Undocumented

logger = (source)

Undocumented

process_time = (source)

Undocumented

processed_rows_count = (source)

Undocumented