Merge pull request #12 from ankitkpandey1/dev

Dev

Author: ankitkpandey1

README.md

@@ -43,7 +43,7 @@ Enqueue task by:
 ```python
 from flyby.brokers.redis import RQueue
 
-task_queue = RQueue(REDIS_URL)
+task_queue = RQueue(REDIS_URL, namespace)
 
 def api_function():
     task_name = 'task'
@@ -123,4 +123,4 @@ Run the setup:
     python setup.py install
 
 ## License
-This software is licensed under the LGPL-2.1 License.
+This software is licensed under the LGPL-2.1 License.

flyby/cli.py

@@ -29,7 +29,7 @@ def main(args=None):
     REDIS_URL = (
         f"redis://{settings.REDIS_HOST}:{settings.REDIS_PORT}/{settings.REDIS_DB}"
     )
-    broker = RQueue(url=REDIS_URL)
+    broker = RQueue(url=REDIS_URL, namespace=settings.NAMESPACE)
 
     running_queues = []
     active_threads = {}

flyby/common/const.py

@@ -6,6 +6,7 @@ class Settings(BaseSettings):
     REDIS_PORT: int
     REDIS_DB: int
     LOG_LOCATION: str
+    NAMESPACE: str
 
     class Config:
         env_file = ".env"

setup.py

@@ -3,7 +3,7 @@
 
 from distutils.core import setup
 
-dependencies = ["redis>=2.0,<5.0", "pytest>=7.1.2", "pydantic-settings>=2.0.3"]
+dependencies = ["redis>=2.0,<5.0", "pytest>=7.1.2", "pydantic-settings==2.1.0"]
 
 setup(
     name="flyby",