Release 0.0.2 (#9)

* Create 0.0.2rc (#8)

* Use ordered data structure to keep track of queue processes (#7)

* Fix potential sync bugs with processes being joined out of order

* A dictionary is unordered, this could cause issues when joining processes since this operation needs to be done in order

* Using a tuple is the best option here, since it is immutable and the structure is simple enough

* push rolling releases with rc branch, not develop

* bump package version to 0.0.2rc

* bump package version to 0.0.2

.github/workflows/publish_rolling_release.yml

@@ -2,7 +2,7 @@ name: Publish Python 🐍 distributions 📦 to TestPyPI
 
 on:
   push:
-    branches: [ develop ]
+    branches: [ "rc" ]
 
 jobs:
   deploy:

setup.py

@@ -5,7 +5,7 @@
 
 setuptools.setup(
     name="queue-automator",
-    version="0.0.1",
+    version="0.0.2",
     author="Wason1797",
     author_email="[email protected]",
     description="A simple wrapper to build queue multiprocessing pipelines",

src/queue_automator/main.py

@@ -192,11 +192,11 @@ def run(self) -> list:
 
         self.__generate_queues(queues, manager, QueueNames.INPUT)
 
-        process_per_queue = {input_queue: self.__spawn_processes(input_queue, output_queue) for input_queue, output_queue in queues}
+        process_per_queue = tuple((input_queue, self.__spawn_processes(input_queue, output_queue)) for input_queue, output_queue in queues)
 
         self.__enqueue_input_data()
 
-        for queue_name, procesess in process_per_queue.items():
+        for queue_name, procesess in process_per_queue:
             current_queue = self.__queue_table[queue_name]
             current_queue['queue'].join()
             self.__signal_queue_exit(current_queue['queue'], current_queue['process_count'])