Skip to content

Commit 7062733

Browse files
committed
Update redis.rs
1 parent 833a596 commit 7062733

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

crates/rustapi-jobs/src/backend/redis.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ impl JobBackend for RedisBackend {
4343
async fn push(&self, job: JobRequest) -> Result<()> {
4444
let mut conn = self
4545
.client
46-
.get_async_connection()
46+
.get_multiplexed_async_connection()
4747
.await
4848
.map_err(|e| JobError::BackendError(e.to_string()))?;
4949

@@ -60,7 +60,7 @@ impl JobBackend for RedisBackend {
6060
async fn pop(&self) -> Result<Option<JobRequest>> {
6161
let mut conn = self
6262
.client
63-
.get_async_connection()
63+
.get_multiplexed_async_connection()
6464
.await
6565
.map_err(|e| JobError::BackendError(e.to_string()))?;
6666

0 commit comments

Comments
 (0)