This is an automated email from the ASF dual-hosted git repository.
mdedetrich pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 5d2eab434 Correctly propagate S3 attributes in tests
5d2eab434 is described below
commit 5d2eab4342f34e39736978b375119107c777cc8d
Author: Matthew de Detrich <[email protected]>
AuthorDate: Sat Apr 29 16:56:38 2023 +0200
Correctly propagate S3 attributes in tests
---
.../stream/connectors/s3/scaladsl/S3IntegrationSpec.scala | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git
a/s3/src/test/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3IntegrationSpec.scala
b/s3/src/test/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3IntegrationSpec.scala
index f39a17627..08025149c 100644
---
a/s3/src/test/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3IntegrationSpec.scala
+++
b/s3/src/test/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3IntegrationSpec.scala
@@ -575,11 +575,11 @@ trait S3IntegrationSpec
case uploadPart if uploadPart.key == sourceKey => uploadPart.uploadId
}
parts <- Future.sequence(uploadIds.map { uploadId =>
- S3.listParts(defaultBucket, sourceKey, uploadId).runWith(Sink.seq)
+ S3.listParts(defaultBucket, sourceKey,
uploadId).withAttributes(attributes).runWith(Sink.seq)
})
// Cleanup the uploads after
_ <- Future.sequence(uploadIds.map { uploadId =>
- S3.deleteUpload(defaultBucket, sourceKey, uploadId)
+ S3.deleteUpload(defaultBucket, sourceKey, uploadId)(implicitly,
attributes)
})
} yield (uploadIds, incomplete, parts.flatten)
@@ -628,7 +628,7 @@ trait S3IntegrationSpec
case uploadPart if uploadPart.key == sourceKey => uploadPart.uploadId
}.get
- parts <- S3.listParts(defaultBucket, sourceKey,
uploadId).runWith(Sink.seq)
+ parts <- S3.listParts(defaultBucket, sourceKey,
uploadId).withAttributes(attributes).runWith(Sink.seq)
remainingData = inputData.slice(3, 6)
_ <- Source(remainingData)
@@ -682,9 +682,9 @@ trait S3IntegrationSpec
case uploadPart if uploadPart.key == sourceKey => uploadPart.uploadId
}.get
- parts <- S3.listParts(defaultBucket, sourceKey,
uploadId).runWith(Sink.seq)
+ parts <- S3.listParts(defaultBucket, sourceKey,
uploadId).withAttributes(attributes).runWith(Sink.seq)
- _ <- S3.completeMultipartUpload(defaultBucket, sourceKey, uploadId,
parts.map(_.toPart))
+ _ <- S3.completeMultipartUpload(defaultBucket, sourceKey, uploadId,
parts.map(_.toPart))(implicitly, attributes)
// This delay is here because sometimes there is a delay when you
complete a large file and its
// actually downloadable
downloaded <- pekko.pattern.after(5.seconds)(
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
