Function execute_query_plan 

pub async fn execute_query_plan<'exec, 'req>(
    ctx: QueryPlanExecutionContext<'exec, 'req>,
) -> Result<PlanExecutionOutput, PlanExecutionError>