enable credentials-login feature for getting login from aws cli

Author: MingweiSamuel

Cargo.lock

@@ -44,6 +44,7 @@ hydro_build_utils = { path = "../hydro_build_utils", version = "^0.0.1", optiona
 
 aws-config = { version = "1", features = [
     "behavior-version-latest",
+    "credentials-login",
 ]}
 aws-sdk-sqs = { version = "1" }
 futures-util = { version = "0.3.0", default-features = false }

hydro_test/Cargo.toml

@@ -13,7 +13,8 @@ use stageleft::q;
 
 type HostCreator = Box<dyn Fn(&mut Deployment) -> Arc<dyn Host>>;
 
-// cargo run -p hydro_test --example aws_sqs --all-features -- --queue-url=https://sqs.us-west-1.amazonaws.com/317211446276/hydro_test_queue
+// aws sqs send-message --queue-url 'https://sqs.us-west-1.amazonaws.com/557701608578/hydro_test_queue_standard' --message-body 'foobar'
+// cargo run -p hydro_test --example aws_sqs --all-features -- --queue-url 'https://sqs.us-west-1.amazonaws.com/557701608578/hydro_test_queue_standard'
 #[derive(Parser, Debug)]
 struct Args {
     #[clap(flatten)]

hydro_test/examples/aws_sqs.rs

@@ -32,8 +32,6 @@ where
     Loc: Location<'a> + NoTick + NoAtomic,
 {
     location
-        .singleton(q!(aws_config::load_defaults(
-            aws_config::BehaviorVersion::latest()
-        )))
+        .singleton(q!(aws_config::load_from_env()))
         .resolve_future_blocking()
 }

hydro_test/src/aws/mod.rs

@@ -30,17 +30,19 @@ pub fn source_sqs_standard<'a, Loc: Location<'a>>(
     queue_url: &'a str,
 ) -> Stream<Message, Loc, Bounded, NoOrder, AtLeastOnce> {
     client
-        .flat_map_stream_unordered(q!(move |client| {
+        .into_stream()
+        .flat_map_stream_blocking(q!(move |client| {
             futures_util::stream::unfold((), move |()| {
                 let fut = self::sqs_recv(&client, queue_url);
                 async move {
-                    let vec = fut.await.expect("Failed to receive from SQS.")?;
+                    let vec = fut.await.expect("Failed to receive from SQS")?;
                     Some((vec, ()))
                 }
             })
             .flat_map(|vec| futures_util::stream::iter(vec))
         }))
         .weaken_retries()
+        .weaken_ordering()
 }
 
 /// Exactly-once in-order delivery from a FIFO SQS queue.
@@ -53,11 +55,12 @@ pub fn source_sqs_fifo<'a, Loc: Location<'a>>(
     _nondet: NonDet,
 ) -> Stream<Message, Loc, Bounded, TotalOrder, ExactlyOnce> {
     client
-        .flat_map_stream_ordered(q!(move |client| {
+        .into_stream()
+        .flat_map_stream_blocking(q!(move |client| {
             futures_util::stream::unfold((), move |()| {
                 let fut = self::sqs_recv(&client, queue_url);
                 async move {
-                    let vec = fut.await.expect("Failed to receive from SQS.")?;
+                    let vec = fut.await.expect("Failed to receive from SQS")?;
                     Some((vec, ()))
                 }
             })