Function poll_loop 

pub async fn poll_loop<T: 'static + AsLogicalPlan, U: 'static + AsExecutionPlan>(
    scheduler: SchedulerGrpcClient<Channel>,
    executor: Arc<Executor>,
    codec: KapotCodec<T, U>,
) -> Result<(), KapotError>