pipeline: add transferLocationID config

Author: sevein

enduro.toml

@@ -37,6 +37,7 @@ user = "test"
 key = "test"
 transferDir = "~/.am/ss-location-data"
 processingDir = ""
+# transferLocationID = "88f6b517-c0cc-411b-8abf-79544ce96f54"
 
 [[hooks."hari"]]
 mock = true

internal/pipeline/pipeline.go

@@ -18,12 +18,13 @@ import (
 // TODO: PipelineRegistry should return Pipeline objects!
 
 type Config struct {
-	Name          string
-	BaseURL       string
-	User          string
-	Key           string
-	TransferDir   string
-	ProcessingDir string
+	Name               string
+	BaseURL            string
+	User               string
+	Key                string
+	TransferDir        string
+	TransferLocationID string
+	ProcessingDir      string
 }
 
 // PipelineRegistry is a collection of known pipelines.

internal/workflow/processing.go

@@ -354,9 +354,20 @@ func (a *TransferActivity) Execute(ctx context.Context, tinfo *TransferInfo) (*T
 		return nil, err
 	}
 
+	config, err := a.manager.Pipelines.Config(tinfo.Event.PipelineName)
+	if err != nil {
+		return nil, err
+	}
+
+	// Transfer path should include the location UUID if defined.
+	var path = tinfo.RelPath
+	if config.TransferLocationID != "" {
+		path = fmt.Sprintf("%s:%s", config.TransferLocationID, path)
+	}
+
 	resp, httpResp, err := amc.Package.Create(ctx, &amclient.PackageCreateRequest{
 		Name:             tinfo.Name,
-		Path:             tinfo.RelPath,
+		Path:             path,
 		ProcessingConfig: tinfo.ProcessingConfig,
 		AutoApprove:      &tinfo.AutoApprove,
 	})