From 2fc73ef8809686c0d539aebddd79c0fa1c9d8bf2 Mon Sep 17 00:00:00 2001 From: LJ Date: Fri, 25 Apr 2025 08:23:33 -0700 Subject: [PATCH] fix(setup): bring back the resource update logic --- src/setup/driver.rs | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) 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(