@@ -17,7 +17,6 @@ import SmithyRetriesAPI
1717
1818// This test class reproduces the "Standard Mode" test cases defined in "Retry Behavior 2.0"
1919final class RetryIntegrationTests : XCTestCase {
20- private let partitionIDKey = AttributeKey < String > ( name: " PartitionID " )
2120 private let partitionID = " partition "
2221
2322 private var context : Context !
@@ -28,7 +27,7 @@ final class RetryIntegrationTests: XCTestCase {
2827 private func setUp( availableCapacity: Int , maxCapacity: Int , maxRetriesBase: Int , maxBackoff: TimeInterval ) async {
2928 // Setup the HTTP context, used by the retry middleware
3029 context = Context ( attributes: Attributes ( ) )
31- context. attributes . set ( key : partitionIDKey , value : partitionID)
30+ context. partitionID = partitionID
3231 context. socketTimeout = 60.0
3332 context. estimatedSkew = 30.0
3433
@@ -239,7 +238,12 @@ private class TestOutputHandler: Handler {
239238 }
240239
241240 func verifyResult( atEnd: Bool = true ) async throws {
242- guard let testStep = latestTestStep else { return }
241+ guard let testStep = latestTestStep else {
242+ if atEnd {
243+ XCTFail ( " No test steps were run! Encountered error: \( String ( describing: finalError!) ) " )
244+ }
245+ return
246+ }
243247
244248 // Test available capacity
245249 let availableCapacity = await quota. availableCapacity
0 commit comments