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