We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 97090a7 commit dd7b86aCopy full SHA for dd7b86a
src/setup/driver.rs
@@ -280,10 +280,13 @@ pub async fn diff_flow_setup_states(
280
.possible_versions()
281
.flat_map(|v| v.sources.iter())
282
{
283
- existing_source_id_to_name_kind
284
- .entry(setup_state.source_id)
285
- .or_default()
286
- .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)
287
+ .or_default()
288
+ .push((&name, &setup_state.source_kind));
289
+ }
290
}
291
292
(existing_source_id_to_name_kind.into_iter())
0 commit comments