bulker: fix

jitsucom · Jan 3, 2024 · 97fef13 · 97fef13
1 parent 1af5d38
commit 97fef13
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/bulkerapp/app/postgres_configuration_source.go b/bulkerapp/app/postgres_configuration_source.go
@@ -171,7 +171,7 @@ func (r *PostgresConfigurationSource) refresh(notify bool) {
 			metrics.ConfigurationSourceError("parse_error").Inc()
 			r.Errorf("failed to parse config for destination %s: %s: %v", connectionId, connectionConfig, err)
 		}
-		if c.UsesBulker {
+		if c.UsesBulker || tp == "sync" {
 			connections[connectionId] = &c
 		}
 	}