Skip to content

Commit

Permalink
chore(deps): bump aws-sdk-sqs from 0.8.0 to 0.9.0 (#211)
Browse files Browse the repository at this point in the history
* chore(deps): bump aws-sdk-sqs from 0.8.0 to 0.9.0

Bumps [aws-sdk-sqs](https://github.com/awslabs/aws-sdk-rust) from 0.8.0 to 0.9.0.
- [Release notes](https://github.com/awslabs/aws-sdk-rust/releases)
- [Changelog](https://github.com/awslabs/aws-sdk-rust/blob/main/CHANGELOG.md)
- [Commits](awslabs/aws-sdk-rust@v0.8.0...v0.9.0)

---
updated-dependencies:
- dependency-name: aws-sdk-sqs
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <[email protected]>

* Unify AWS dependencies

* Update all AWS deps at once

Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Santiago Carmuega <[email protected]>
  • Loading branch information
dependabot[bot] and scarmuega authored Mar 20, 2022
1 parent 2e29691 commit 392fcf9
Show file tree
Hide file tree
Showing 4 changed files with 54 additions and 55 deletions.
77 changes: 39 additions & 38 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

6 changes: 3 additions & 3 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -50,9 +50,9 @@ elasticsearch = { version = "7.14.0-alpha.1", optional = true }
murmur3 = { version = "0.5.1", optional = true }

# feature: aws
aws-config = { version = "0.8.0", optional = true }
aws-sdk-sqs = { version = "0.8.0", optional = true }
aws-sdk-lambda = { version = "0.8.0", optional = true }
aws-config = { version = "0.9.0", optional = true }
aws-sdk-sqs = { version = "0.9.0", optional = true }
aws-sdk-lambda = { version = "0.9.0", optional = true }

# features: elasticsearch || aws
tokio = { version = "1.17.0", optional = true, features = ["rt"] }
Expand Down
13 changes: 6 additions & 7 deletions src/sinks/aws_lambda/setup.rs
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@
use aws_config::{self, meta::region::RegionProviderChain, RetryConfig};
use aws_sdk_lambda::{Client, Region};
use aws_sdk_lambda::{Client, Region, RetryConfig};
use serde::Deserialize;

use crate::{
Expand All @@ -22,11 +21,11 @@ impl SinkProvider for WithUtils<Config> {
fn bootstrap(&self, input: StageReceiver) -> BootstrapResult {
let explicit_region = self.inner.region.to_owned();

let region_provider =
RegionProviderChain::first_try(Region::new(explicit_region)).or_default_provider();

let aws_config = tokio::runtime::Runtime::new()?
.block_on(aws_config::from_env().region(region_provider).load());
let aws_config = tokio::runtime::Runtime::new()?.block_on(
aws_config::from_env()
.region(Region::new(explicit_region))
.load(),
);

let retry_config = RetryConfig::new()
.with_max_attempts(self.inner.max_retries.unwrap_or(DEFAULT_MAX_RETRIES));
Expand Down
13 changes: 6 additions & 7 deletions src/sinks/aws_sqs/setup.rs
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@
use aws_config::{self, meta::region::RegionProviderChain, RetryConfig};
use aws_sdk_sqs::{Client, Region};
use aws_sdk_sqs::{Client, Region, RetryConfig};
use serde::Deserialize;

use crate::{
Expand All @@ -24,11 +23,11 @@ impl SinkProvider for WithUtils<Config> {
fn bootstrap(&self, input: StageReceiver) -> BootstrapResult {
let explicit_region = self.inner.region.to_owned();

let region_provider =
RegionProviderChain::first_try(Region::new(explicit_region)).or_default_provider();

let aws_config = tokio::runtime::Runtime::new()?
.block_on(aws_config::from_env().region(region_provider).load());
let aws_config = tokio::runtime::Runtime::new()?.block_on(
aws_config::from_env()
.region(Region::new(explicit_region))
.load(),
);

let retry_config = RetryConfig::new()
.with_max_attempts(self.inner.max_retries.unwrap_or(DEFAULT_MAX_RETRIES));
Expand Down

0 comments on commit 392fcf9

Please sign in to comment.