bug: fixes overwriting the sf bundles during export #309

apigee · Oct 5, 2023 · 18c6402 · 18c6402
1 parent 598d6f5
commit 18c6402
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/internal/client/sharedflows/sharedflows.go b/internal/client/sharedflows/sharedflows.go
@@ -333,7 +333,7 @@ func Export(conn int, folder string, allRevisions bool) (err error) {
 
 	for i := 0; i < conn; i++ {
 		fanOutWg.Add(1)
-		go exportSharedFlows(&fanOutWg, jobChan, folder, errChan)
+		go exportSharedFlows(&fanOutWg, jobChan, folder, allRevisions, errChan)
 	}
 
 	for _, proxy := range shrdflows.Flows {
@@ -357,14 +357,14 @@ func Export(conn int, folder string, allRevisions bool) (err error) {
 	return nil
 }
 
-func exportSharedFlows(wg *sync.WaitGroup, jobs <-chan revision, folder string, errs chan<- error) {
+func exportSharedFlows(wg *sync.WaitGroup, jobs <-chan revision, folder string, allRevisions bool, errs chan<- error) {
 	defer wg.Done()
 	for {
 		job, ok := <-jobs
 		if !ok {
 			return
 		}
-		err := apiclient.FetchBundle("sharedflows", folder, job.name, job.rev, false)
+		err := apiclient.FetchBundle("sharedflows", folder, job.name, job.rev, allRevisions)
 		if err != nil {
 			errs <- err
 		}