add ipfs swarm addresss env set (#674)

labdao · Sep 27, 2023 · 16d0986 · 16d0986
1 parent 2f0492c
commit 16d0986
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/bacalhau/bacalhau.go b/internal/bacalhau/bacalhau.go
@@ -130,6 +130,9 @@ func DownloadBacalhauResults(dir string, submittedJob *model.Job, results []mode
 		Timeout:   model.DefaultIPFSTimeout,
 		OutputDir: dir,
 	}
+	if os.Getenv("BACALHAU_IPFS_SWARM_ADDRESSES") != "" {
+		downloadSettings.IPFSSwarmAddrs = os.Getenv("BACALHAU_IPFS_SWARM_ADDRESSES")
+	}
 	downloadSettings.OutputDir = dir
 	downloaderProvider := util.NewStandardDownloaders(cm, downloadSettings)
 	err := downloader.DownloadResults(context.Background(), results, downloaderProvider, downloadSettings)