diff --git a/src/setup/driver.rs b/src/setup/driver.rs index 96f53d5ad..1e2c950ba 100644 --- a/src/setup/driver.rs +++ b/src/setup/driver.rs @@ -1,11 +1,7 @@ use crate::{lib_context::get_auth_registry, prelude::*}; -use indexmap::IndexMap; -use serde::de::DeserializeOwned; use sqlx::PgPool; use std::{ - borrow::Cow, - collections::{BTreeMap, BTreeSet, HashMap, HashSet}, fmt::{Debug, Display}, str::FromStr, }; @@ -457,6 +453,9 @@ pub async fn apply_changes( if let Some(tracking_table) = &flow_status.tracking_table { maybe_update_resource_setup(write, tracking_table).await?; } + for target_resource in &flow_status.target_resources { + maybe_update_resource_setup(write, target_resource).await?; + } let is_deletion = flow_status.status == ObjectStatus::Deleted; db_metadata::commit_changes_for_flow(