Skip to content

Commit

Permalink
disable stalled stream protection
Browse files Browse the repository at this point in the history
  • Loading branch information
eaypek-tfh committed Jan 15, 2025
1 parent bd961ff commit 796fbc2
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 6 deletions.
2 changes: 1 addition & 1 deletion .github/workflows/temp-branch-build-and-push.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ name: Branch - Build and push docker image
on:
push:
branches:
- "feat/even-odd-import-from-s3"
- "chore/increase-stalled-stream-protection"

concurrency:
group: '${{ github.workflow }} @ ${{ github.event.pull_request.head.label || github.head_ref || github.ref }}'
Expand Down
7 changes: 2 additions & 5 deletions iris-mpc/src/bin/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -692,12 +692,9 @@ async fn server_main(config: Config) -> eyre::Result<()> {
// Increase S3 retries to 5
let retry_config = RetryConfig::standard().with_max_attempts(5);

// Bump stalled stream protection grace period to 30 seconds
let mut stream_protection = StalledStreamProtectionConfig::enabled();
stream_protection.set_grace_period(Some(Duration::from_secs(40)));

let s3_config = S3ConfigBuilder::from(&shared_config)
.stalled_stream_protection(stream_protection.build())
// disable stalled stream protection to avoid panics during s3 import
.stalled_stream_protection(StalledStreamProtectionConfig::disabled())
.retry_config(retry_config)
.build();
let s3_client = Arc::new(S3Client::from_conf(s3_config));
Expand Down

0 comments on commit 796fbc2

Please sign in to comment.