fix: Remove pipeline with identic name when not successfuly created.

Causes inifinite errors during Opening pipeline because of not removing the pipeline due to network error.
keboola · Feb 13, 2025 · 4840779 · 4840779
1 parent 458f1c9
commit 4840779
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/pkg/service/stream/storage/level/local/encoding/manager.go b/internal/pkg/service/stream/storage/level/local/encoding/manager.go
@@ -114,6 +114,7 @@ func (m *Manager) OpenPipeline(
 		closeFunc,
 	)
 	if err != nil {
+		m.removePipeline(sliceKey)
 		return nil, err
 	}