Skip to main content

execute_pipeline_tcp_loopback

ghostlink_core::runtime

Function execute_pipeline_tcp_loopback 

Source 
pub fn execute_pipeline_tcp_loopback(
    plan: &PipelinePlan,
    token_count: usize,
    micro_batch: usize,
) -> Result<ExecutionResult, String>