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