From 5ed5c79b4b80b72cd44a57cf469b28f85913f5ec Mon Sep 17 00:00:00 2001 From: jedarden Date: Fri, 8 May 2026 20:41:28 -0400 Subject: [PATCH] Fix remaining Redis type annotations Add explicit type parameters to additional Redis calls (lpush, etc.) to resolve type inference issues with the redis crate on Rust 1.87. Co-Authored-By: Claude Opus 4.7 --- crates/miroir-core/src/task_store/redis.rs | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/crates/miroir-core/src/task_store/redis.rs b/crates/miroir-core/src/task_store/redis.rs index 729a982..56fecbc 100644 --- a/crates/miroir-core/src/task_store/redis.rs +++ b/crates/miroir-core/src/task_store/redis.rs @@ -506,11 +506,11 @@ impl TaskStore for RedisTaskStore { let key = self.table_key("canary_runs", &run.run_id); let data = serde_json::to_string(run)?; - conn.set(&key, data).await?; + conn.set::<_, _, ()>(&key, data).await?; // Add to canary-specific runs list let canary_runs_key = format!("miroir:canary_runs:{}:index", run.canary_name); - conn.lpush(&canary_runs_key, &run.run_id).await?; + conn.lpush::<_, _, ()>(&canary_runs_key, &run.run_id).await?; Ok(()) } @@ -561,7 +561,7 @@ impl TaskStore for RedisTaskStore { let key = self.table_key("cdc_cursors", &format!("{}:{}", cursor.sink, cursor.index)); let data = serde_json::to_string(cursor)?; - conn.set(&key, data).await?; + conn.set::<_, _, ()>(&key, data).await?; Ok(()) } @@ -577,10 +577,10 @@ impl TaskStore for RedisTaskStore { let key = self.table_key("tenant_map", &tenant.api_key); let data = serde_json::to_string(tenant)?; - conn.set(&key, data).await?; + conn.set::<_, _, ()>(&key, data).await?; let index_key = self.index_key("tenant_map"); - conn.sadd(&index_key, &tenant.api_key).await?; + conn.sadd::<_, _, ()>(&index_key, &tenant.api_key).await?; Ok(()) } @@ -604,8 +604,8 @@ impl TaskStore for RedisTaskStore { let key = self.table_key("tenant_map", api_key); let index_key = self.index_key("tenant_map"); - conn.del(&key).await?; - conn.srem(&index_key, api_key).await?; + conn.del::<_, ()>(&key).await?; + conn.srem::<_, _, ()>(&index_key, api_key).await?; Ok(()) }