diff --git a/src/writer/serve.py b/src/writer/serve.py index 85078f30..417ef94c 100644 --- a/src/writer/serve.py +++ b/src/writer/serve.py @@ -109,10 +109,10 @@ class RedisJobVault(JobVault): DEFAULT_TTL = 86400 def __init__(self): - import redis + import redis # type: ignore super().__init__() redis_connection_string = os.getenv("WRITER_PERSISTENT_STORE") - self.redis_client = redis.from_url(redis_connection_string, decode_responses=True, socket_timeout=30) # type: ignore + self.redis_client = redis.from_url(redis_connection_string, decode_responses=True, socket_timeout=30) self.counter_key = "job_counter" if not self.redis_client.exists(self.counter_key): self.redis_client.set(self.counter_key, 0)