Skip to content

Commit

Permalink
fix: Mypy fix
Browse files Browse the repository at this point in the history
  • Loading branch information
ramedina86 committed Dec 16, 2024
1 parent 0c47048 commit 227f1f0
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/writer/serve.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 227f1f0

Please sign in to comment.