Skip if no such key (#7)

Wh1isper · Jul 10, 2024 · b306d75 · b306d75
1 parent cdbdbd8
commit b306d75
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/redis_canal/agent.py b/redis_canal/agent.py
@@ -175,8 +175,8 @@ async def _get_redis_stream_keys(self) -> list[str]:
                 await self.redis_client.xinfo_stream(self.redis_stream_key)
             except redis.ResponseError:
                 logger.error(f"{self.redis_stream_key} is not a stream or does not exist")
-                raise
-            keys.append(self.redis_stream_key)
+            else:
+                keys.append(self.redis_stream_key)
 
         if self.redis_stream_key_prefix:
             if self.redis_stream_key_prefix == "*":