Skip to content

Commit dcf9646

Browse files
thomhurstclaude
andauthored
feat: Add CancellationToken support to AWS S3 methods (#1718)
Add CancellationToken parameter (with default value) to all S3 bucket operation methods, allowing pipeline cancellation to propagate to AWS SDK calls. Also adds ConfigureAwait(false) for consistency. Affected methods: - Bucket, BucketEncryption, BucketLogging, BucketPolicy - BucketWebsite, BucketNotification, BucketReplication - BucketTagging, BucketVersioning, BucketAccelerateConfiguration - BucketAnalyticsConfiguration, BucketInventoryConfiguration - BucketMetricsConfiguration, BucketOwnershipControls - BucketRequestPayment, BucketIntelligentTieringConfiguration Fixes #1544 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-authored-by: Claude Opus 4.5 <noreply@anthropic.com>
1 parent e37c200 commit dcf9646

1 file changed

Lines changed: 33 additions & 33 deletions

File tree

  • src/ModularPipelines.AmazonWebServices

src/ModularPipelines.AmazonWebServices/S3.cs

Lines changed: 33 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -14,83 +14,83 @@ public S3(AmazonS3Client client)
1414
Client = client;
1515
}
1616

17-
public async Task<PutBucketResponse> Bucket(PutBucketRequest request)
17+
public async Task<PutBucketResponse> Bucket(PutBucketRequest request, CancellationToken cancellationToken = default)
1818
{
19-
return await Client.PutBucketAsync(request);
19+
return await Client.PutBucketAsync(request, cancellationToken).ConfigureAwait(false);
2020
}
2121

22-
public async Task<PutBucketEncryptionResponse> BucketEncryption(PutBucketEncryptionRequest request)
22+
public async Task<PutBucketEncryptionResponse> BucketEncryption(PutBucketEncryptionRequest request, CancellationToken cancellationToken = default)
2323
{
24-
return await Client.PutBucketEncryptionAsync(request);
24+
return await Client.PutBucketEncryptionAsync(request, cancellationToken).ConfigureAwait(false);
2525
}
2626

27-
public async Task<PutBucketLoggingResponse> BucketLogging(PutBucketLoggingRequest request)
27+
public async Task<PutBucketLoggingResponse> BucketLogging(PutBucketLoggingRequest request, CancellationToken cancellationToken = default)
2828
{
29-
return await Client.PutBucketLoggingAsync(request);
29+
return await Client.PutBucketLoggingAsync(request, cancellationToken).ConfigureAwait(false);
3030
}
3131

32-
public async Task<PutBucketPolicyResponse> BucketPolicy(PutBucketPolicyRequest request)
32+
public async Task<PutBucketPolicyResponse> BucketPolicy(PutBucketPolicyRequest request, CancellationToken cancellationToken = default)
3333
{
34-
return await Client.PutBucketPolicyAsync(request);
34+
return await Client.PutBucketPolicyAsync(request, cancellationToken).ConfigureAwait(false);
3535
}
3636

37-
public async Task<PutBucketWebsiteResponse> BucketWebsite(PutBucketWebsiteRequest request)
37+
public async Task<PutBucketWebsiteResponse> BucketWebsite(PutBucketWebsiteRequest request, CancellationToken cancellationToken = default)
3838
{
39-
return await Client.PutBucketWebsiteAsync(request);
39+
return await Client.PutBucketWebsiteAsync(request, cancellationToken).ConfigureAwait(false);
4040
}
4141

42-
public async Task<PutBucketNotificationResponse> BucketNotification(PutBucketNotificationRequest request)
42+
public async Task<PutBucketNotificationResponse> BucketNotification(PutBucketNotificationRequest request, CancellationToken cancellationToken = default)
4343
{
44-
return await Client.PutBucketNotificationAsync(request);
44+
return await Client.PutBucketNotificationAsync(request, cancellationToken).ConfigureAwait(false);
4545
}
4646

47-
public async Task<PutBucketReplicationResponse> BucketReplication(PutBucketReplicationRequest request)
47+
public async Task<PutBucketReplicationResponse> BucketReplication(PutBucketReplicationRequest request, CancellationToken cancellationToken = default)
4848
{
49-
return await Client.PutBucketReplicationAsync(request);
49+
return await Client.PutBucketReplicationAsync(request, cancellationToken).ConfigureAwait(false);
5050
}
5151

52-
public async Task<PutBucketTaggingResponse> BucketTagging(PutBucketTaggingRequest request)
52+
public async Task<PutBucketTaggingResponse> BucketTagging(PutBucketTaggingRequest request, CancellationToken cancellationToken = default)
5353
{
54-
return await Client.PutBucketTaggingAsync(request);
54+
return await Client.PutBucketTaggingAsync(request, cancellationToken).ConfigureAwait(false);
5555
}
5656

57-
public async Task<PutBucketVersioningResponse> BucketVersioning(PutBucketVersioningRequest request)
57+
public async Task<PutBucketVersioningResponse> BucketVersioning(PutBucketVersioningRequest request, CancellationToken cancellationToken = default)
5858
{
59-
return await Client.PutBucketVersioningAsync(request);
59+
return await Client.PutBucketVersioningAsync(request, cancellationToken).ConfigureAwait(false);
6060
}
6161

62-
public async Task<PutBucketAccelerateConfigurationResponse> BucketAccelerateConfiguration(PutBucketAccelerateConfigurationRequest request)
62+
public async Task<PutBucketAccelerateConfigurationResponse> BucketAccelerateConfiguration(PutBucketAccelerateConfigurationRequest request, CancellationToken cancellationToken = default)
6363
{
64-
return await Client.PutBucketAccelerateConfigurationAsync(request);
64+
return await Client.PutBucketAccelerateConfigurationAsync(request, cancellationToken).ConfigureAwait(false);
6565
}
6666

67-
public async Task<PutBucketAnalyticsConfigurationResponse> BucketAnalyticsConfiguration(PutBucketAnalyticsConfigurationRequest request)
67+
public async Task<PutBucketAnalyticsConfigurationResponse> BucketAnalyticsConfiguration(PutBucketAnalyticsConfigurationRequest request, CancellationToken cancellationToken = default)
6868
{
69-
return await Client.PutBucketAnalyticsConfigurationAsync(request);
69+
return await Client.PutBucketAnalyticsConfigurationAsync(request, cancellationToken).ConfigureAwait(false);
7070
}
7171

72-
public async Task<PutBucketInventoryConfigurationResponse> BucketInventoryConfiguration(PutBucketInventoryConfigurationRequest request)
72+
public async Task<PutBucketInventoryConfigurationResponse> BucketInventoryConfiguration(PutBucketInventoryConfigurationRequest request, CancellationToken cancellationToken = default)
7373
{
74-
return await Client.PutBucketInventoryConfigurationAsync(request);
74+
return await Client.PutBucketInventoryConfigurationAsync(request, cancellationToken).ConfigureAwait(false);
7575
}
7676

77-
public async Task<PutBucketMetricsConfigurationResponse> BucketMetricsConfiguration(PutBucketMetricsConfigurationRequest request)
77+
public async Task<PutBucketMetricsConfigurationResponse> BucketMetricsConfiguration(PutBucketMetricsConfigurationRequest request, CancellationToken cancellationToken = default)
7878
{
79-
return await Client.PutBucketMetricsConfigurationAsync(request);
79+
return await Client.PutBucketMetricsConfigurationAsync(request, cancellationToken).ConfigureAwait(false);
8080
}
8181

82-
public async Task<PutBucketOwnershipControlsResponse> BucketOwnershipControls(PutBucketOwnershipControlsRequest request)
82+
public async Task<PutBucketOwnershipControlsResponse> BucketOwnershipControls(PutBucketOwnershipControlsRequest request, CancellationToken cancellationToken = default)
8383
{
84-
return await Client.PutBucketOwnershipControlsAsync(request);
84+
return await Client.PutBucketOwnershipControlsAsync(request, cancellationToken).ConfigureAwait(false);
8585
}
8686

87-
public async Task<PutBucketRequestPaymentResponse> BucketRequestPayment(PutBucketRequestPaymentRequest request)
87+
public async Task<PutBucketRequestPaymentResponse> BucketRequestPayment(PutBucketRequestPaymentRequest request, CancellationToken cancellationToken = default)
8888
{
89-
return await Client.PutBucketRequestPaymentAsync(request);
89+
return await Client.PutBucketRequestPaymentAsync(request, cancellationToken).ConfigureAwait(false);
9090
}
9191

92-
public async Task<PutBucketIntelligentTieringConfigurationResponse> BucketIntelligentTieringConfiguration(PutBucketIntelligentTieringConfigurationRequest request)
92+
public async Task<PutBucketIntelligentTieringConfigurationResponse> BucketIntelligentTieringConfiguration(PutBucketIntelligentTieringConfigurationRequest request, CancellationToken cancellationToken = default)
9393
{
94-
return await Client.PutBucketIntelligentTieringConfigurationAsync(request);
94+
return await Client.PutBucketIntelligentTieringConfigurationAsync(request, cancellationToken).ConfigureAwait(false);
9595
}
96-
}
96+
}

0 commit comments

Comments
 (0)