diff --git a/.github/workflows/lint.yml b/.github/workflows/lint.yml index 171d0e9..47ba49d 100644 --- a/.github/workflows/lint.yml +++ b/.github/workflows/lint.yml @@ -45,7 +45,7 @@ jobs: run: cargo hack --each-feature clippy --all-targets -- -D warnings - name: Start test dependencies - run: docker-compose -f "./testing-docker-compose.yml" up -d + run: docker compose -f "./testing-docker-compose.yml" up -d - name: Run tests env: @@ -55,7 +55,7 @@ jobs: run: cargo test --all-features - name: Stop test dependencies - run: docker-compose -f "./testing-docker-compose.yml" down + run: docker compose -f "./testing-docker-compose.yml" down typos: name: Check for typos diff --git a/omniqueue/src/backends/redis/fallback.rs b/omniqueue/src/backends/redis/fallback.rs index f36a768..061eb30 100644 --- a/omniqueue/src/backends/redis/fallback.rs +++ b/omniqueue/src/backends/redis/fallback.rs @@ -96,7 +96,8 @@ impl Acker for RedisFallbackAcker { self.already_acked_or_nacked = true; - self.redis + let _: () = self + .redis .get() .await .map_err(QueueError::generic)? diff --git a/omniqueue/src/backends/redis/mod.rs b/omniqueue/src/backends/redis/mod.rs index 0a2ce7c..f91e44e 100644 --- a/omniqueue/src/backends/redis/mod.rs +++ b/omniqueue/src/backends/redis/mod.rs @@ -550,7 +550,8 @@ impl RedisProducer { pub async fn send_raw_scheduled(&self, payload: &[u8], delay: Duration) -> Result<()> { let timestamp = unix_timestamp(SystemTime::now() + delay).map_err(QueueError::generic)?; - self.redis + let _: () = self + .redis .get() .await .map_err(QueueError::generic)?