Skip to content

Commit 2fc73ef

Browse files
committed
fix(setup): bring back the resource update logic
1 parent a8c863f commit 2fc73ef

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

src/setup/driver.rs

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,7 @@
11
use crate::{lib_context::get_auth_registry, prelude::*};
22

3-
use indexmap::IndexMap;
4-
use serde::de::DeserializeOwned;
53
use sqlx::PgPool;
64
use std::{
7-
borrow::Cow,
8-
collections::{BTreeMap, BTreeSet, HashMap, HashSet},
95
fmt::{Debug, Display},
106
str::FromStr,
117
};
@@ -457,6 +453,9 @@ pub async fn apply_changes(
457453
if let Some(tracking_table) = &flow_status.tracking_table {
458454
maybe_update_resource_setup(write, tracking_table).await?;
459455
}
456+
for target_resource in &flow_status.target_resources {
457+
maybe_update_resource_setup(write, target_resource).await?;
458+
}
460459

461460
let is_deletion = flow_status.status == ObjectStatus::Deleted;
462461
db_metadata::commit_changes_for_flow(

0 commit comments

Comments
 (0)