Skip to main content

handle_flow_notification

servers::pending_rows_batcher

Function handle_flow_notification 

Source 
async fn handle_flow_notification(
    notification: FlowNotification,
    table_flownode_set_cache: TableFlownodeSetCacheRef,
    node_manager: NodeManagerRef,
)