chore: Fix warnings on integration tests (#2041)

Author: jbelkins

IntegrationTests/AWSIntegrationTestUtils/ConcurrentTestHelper.swift

@@ -36,6 +36,7 @@ public func repeatConcurrently(
 ///   - test: The function pointer for the test to run
 ///   - args: Any values to pass along to test function
 /// - Throws: Any error thrown by one of the test runs.
+@Sendable
 public func repeatConcurrentlyWithArgs<Arg: Sendable>(
     count: Int,
     test: @escaping @Sendable (Arg) async throws -> Void,

IntegrationTests/Services/AWSBedrockRuntimeIntegrationTests/InvokeModelWithBidirectionalStreamTest.swift

@@ -193,7 +193,7 @@ final class InvokeModelWithBidirectionalStreamTest: XCTestCase {
         (inputStream, continuation) = AsyncThrowingStream.makeStream()
 
         // Start up background task that feeds events to the stream.
-        Task {
+        Task { [CONTENT_END_EVENT, PROMPT_END_EVENT, requestEvents] in
             for event in requestEvents {
                 let currentEvent = BedrockRuntimeClientTypes.InvokeModelWithBidirectionalStreamInput.chunk(
                     BedrockRuntimeClientTypes.BidirectionalInputPayloadPart(bytes: event.data(using: .utf8))

IntegrationTests/Services/AWSDynamoDBIntegrationTests/AccountIDEndpointModeTests.swift

@@ -137,7 +137,7 @@ final class AccountIDEndpointModeTests: XCTestCase {
     ) async throws -> DynamoDBClient {
         let accountID = setAccountID ? self.accountID : nil
         let credentials = AWSCredentialIdentity(accessKey: "abc", secret: "def", accountID: accountID)
-        let resolver = try StaticAWSCredentialIdentityResolver(credentials)
+        let resolver = StaticAWSCredentialIdentityResolver(credentials)
         let config = try await DynamoDBClient.Config(
             awsCredentialIdentityResolver: resolver,
             region: "us-east-1",

IntegrationTests/Services/AWSDynamoDBIntegrationTests/QueryCompatibleSanityCheck.swift

@@ -38,7 +38,7 @@ final class QueryCompatibleTest: XCTestCase {
         }
 
         let credentials = AWSCredentialIdentity(accessKey: "test", secret: "test")
-        let resolver = try StaticAWSCredentialIdentityResolver(credentials)
+        let resolver = StaticAWSCredentialIdentityResolver(credentials)
 
         let config = try await DynamoDBClient.Config(
             awsCredentialIdentityResolver: resolver,

IntegrationTests/Services/AWSS3IntegrationTests/S3ConcurrentTests.swift

@@ -39,6 +39,7 @@ final class S3ConcurrentTests: S3XCTestCase, @unchecked Sendable {
     // MARK: - Private methods
 
     // Puts data to S3, gets the uploaded file, asserts retrieved data == original data, deletes S3 object
+    @Sendable
     private func getObject(data: Data) async throws {
        let objectKey = UUID().uuidString.split(separator: "-").first!.lowercased()
        let putObjectInput = PutObjectInput(body: .data(data), bucket: bucketName, key: objectKey)

IntegrationTests/Services/AWSS3IntegrationTests/S3ErrorTests.swift

@@ -75,7 +75,7 @@ class S3ErrorTests: S3XCTestCase {
     func test_InvalidAccessKeyID_isThrownWhenAppropriate() async throws {
         do {
             let credentials = AWSCredentialIdentity(accessKey: "AKIDEXAMPLE", secret: "wJalrXUtnFEMI/K7MDENG+bPxRfiCYEXAMPLEKEY")
-            let awsCredentialIdentityResolver = try StaticAWSCredentialIdentityResolver(credentials)
+            let awsCredentialIdentityResolver = StaticAWSCredentialIdentityResolver(credentials)
             let config = try await S3Client.S3ClientConfiguration(awsCredentialIdentityResolver: awsCredentialIdentityResolver, region: region)
             let input = GetObjectInput(bucket: bucketName, key: UUID().uuidString)
             _ = try await S3Client(config: config).getObject(input: input)

IntegrationTests/Services/AWSTranscribeStreamingIntegrationTests/TranscribeStreamingTests.swift

@@ -115,6 +115,7 @@ final class TranscribeStreamingTests: XCTestCase, @unchecked Sendable {
     //
     // Normal retry is not applied to transcribe streaming because the request body is a
     // non-rewindable stream.
+    @Sendable
     private func attempt() async throws {
         // These throttling / resource limit errors may be returned based on the number of
         // recent requests made to AWSTranscribeStreaming.