Increase upload buffer size in send to failed

artefactual-sdps · Dec 4, 2023 · 9906473 · 9906473
1 parent b0cb15c
commit 9906473
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/internal/sfa/activities/send_to_failed_bucket.go b/internal/sfa/activities/send_to_failed_bucket.go
@@ -42,12 +42,16 @@ func (sf *SendToFailedBucketActivity) Execute(ctx context.Context, params *SendT
 		return nil, err
 	}
 	res.FailedKey = "Failed_" + params.Key
+	writerOptions := &blob.WriterOptions{
+		ContentType: "application/octet-stream",
+		BufferSize:  100_000_000,
+	}
 
 	switch params.FailureType {
 	case FailureTransfer:
-		err = sf.failedTransferBucket.Upload(ctx, res.FailedKey, f, &blob.WriterOptions{ContentType: "application/octet-stream"})
+		err = sf.failedTransferBucket.Upload(ctx, res.FailedKey, f, writerOptions)
 	case FailureSIP:
-		err = sf.failedSipBucket.Upload(ctx, res.FailedKey, f, &blob.WriterOptions{ContentType: "application/octet-stream"})
+		err = sf.failedSipBucket.Upload(ctx, res.FailedKey, f, writerOptions)
 	}
 	if err != nil {
 		return nil, err