Skip to content

Commit 08a46f5

Browse files
committed
fix: large executions not working in non-main regions (1)
1 parent d400b6d commit 08a46f5

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

db-connector.go

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1603,14 +1603,13 @@ func getExecutionFileValue(ctx context.Context, workflowExecution WorkflowExecut
16031603
if err != nil {
16041604
log.Printf("[ERROR] Failed reading file from bucket %s: %s. Will try with alternative solution.", bucketName, err)
16051605

1606-
// try reading instead from other bucket
16071606
if projectName != "shuffler" {
16081607
bucketName = fmt.Sprintf("%s.appspot.com", projectName)
1608+
bucket = project.StorageClient.Bucket(bucketName)
1609+
obj = bucket.Object(fullParsedPath)
1610+
fileReader, err = obj.NewReader(ctx)
16091611
}
16101612

1611-
bucket = project.StorageClient.Bucket(bucketName)
1612-
obj = bucket.Object(fullParsedPath)
1613-
fileReader, err = obj.NewReader(ctx)
16141613
if err != nil {
16151614
log.Printf("[ERROR] Failed reading file again from bucket %s: %s", bucketName, err)
16161615
}

0 commit comments

Comments
 (0)