From ac139c6031d8ea3cec2ffe719436d4a8b636694c Mon Sep 17 00:00:00 2001 From: Jiangzhou He Date: Sun, 24 Aug 2025 20:36:43 -0700 Subject: [PATCH] fix: ignore empty kind on creating legacy source list for compatibility --- src/setup/driver.rs | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/src/setup/driver.rs b/src/setup/driver.rs index 2a8723fb4..68ea06eea 100644 --- a/src/setup/driver.rs +++ b/src/setup/driver.rs @@ -280,10 +280,13 @@ pub async fn diff_flow_setup_states( .possible_versions() .flat_map(|v| v.sources.iter()) { - existing_source_id_to_name_kind - .entry(setup_state.source_id) - .or_default() - .push((&name, &setup_state.source_kind)); + // For backward compatibility, we only process source states for non-empty source kinds. + if !setup_state.source_kind.is_empty() { + existing_source_id_to_name_kind + .entry(setup_state.source_id) + .or_default() + .push((&name, &setup_state.source_kind)); + } } (existing_source_id_to_name_kind.into_iter())