Fix: Queue unintentionally sharing same workers

iann838 · Jan 26, 2023 · a3b965b · a3b965b
1 parent 5558a49
commit a3b965b
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 5 deletions.
diff --git a/README.md b/README.md
@@ -8,8 +8,8 @@ Pyot is an asyncIO based high-level Python Riot Games API framework which encour
 
 | Index | Version |
 | ---- | ------- |
-| PyPI | `6.0.7` |
-| master | `6.0.7` |
+| PyPI | `6.0.8` |
+| master | `6.0.8` |
 
 If you're migrating your project to a newer version of Pyot, please refer to **Changelog** section of the [documentation](https://pyot.paaksing.com).
 

diff --git a/docs/README.md b/docs/README.md
@@ -8,8 +8,8 @@ Pyot is an asyncIO based high-level Python Riot Games API framework which encour
 
 | Index | Version |
 | ---- | ------- |
-| PyPI | `6.0.7` |
-| master | `6.0.7` |
+| PyPI | `6.0.8` |
+| master | `6.0.8` |
 
 If you're migrating your project to a newer version of Pyot, please refer to **Changelog** section of the documentation.
 

diff --git a/pyot/core/queue.py b/pyot/core/queue.py
@@ -37,11 +37,15 @@ def __init__(self, workers: int = 25, maxsize: int = None, log_level: int = 0, e
         if workers < 1: raise ValueError('Number of workers must be an integer greater than 0')
         self.workers = workers
         self.exception_handler = exception_handler
+        self.responses = {}
+        self.worker_tasks = []
         if maxsize is None:
             self.maxsize = workers * 2
         else:
             self.maxsize = maxsize
         self.log_level = log_level
+        self._queue = asyncio.Queue(maxsize=self.maxsize)
+        self._id_counter = 0
 
     async def worker(self, queue: asyncio.Queue):
         while True:

diff --git a/setup.py b/setup.py
@@ -32,7 +32,7 @@
 
 setup(
     name="pyot",
-    version="6.0.7",
+    version="6.0.8",
     author="Paaksing",
     author_email="paaksingtech@gmail.com",
     url="https://github.com/paaksing/Pyot",