Skip to content

Commit ba087df

Browse files
committed
Add async initializer for Redis and Lua script setup
1 parent 551cf6b commit ba087df

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/fq/queue.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,10 @@ def __init__(self, config_path):
3939
self._load_config()
4040
self._r = None # redis client placeholder
4141

42+
async def initialize(self):
43+
"""Async initializer to set up redis and lua scripts."""
44+
await self._initialize()
45+
4246
async def _initialize(self):
4347
"""Read the FQ configuration and set up redis + Lua scripts."""
4448

0 commit comments

Comments
 (0)