fn execute_node( plan: Arc<Plan>, node_index: usize, tx: Sender<Result<RtdlEvent, Status>>, atlas: AtlasClient, provider_id: String, runtime: PlanRuntime, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'static>>