- Minor bugfixes

Author: rtu-dataframe

django-queue-manager/django_queue_manager.egg-info/PKG-INFO

@@ -1,6 +1,6 @@
 Metadata-Version: 1.1
 Name: django-queue-manager
-Version: 1.3.1
+Version: 1.3.2
 Summary: A simple app that provides a Message Queue System using a socket as broker, this app, make you able to manage an ordered queue of tasks (with calling a simple queuing function form API).Simple to setup, easy to manage and scalable, the queue can be remotized to another server,you can use multiple istance of the application, and easly manage multiple broker and relatives queues.This app, will integrate into your DB backend and serves three table with the states of the queue.
 Home-page: http://www.fardellasimone.com/
 Author: Fardella Simone

django-queue-manager/django_queue_manager.egg-info/SOURCES.txt

@@ -17,6 +17,7 @@ django_queue_manager.egg-info/PKG-INFO
 django_queue_manager.egg-info/SOURCES.txt
 django_queue_manager.egg-info/dependency_links.txt
 django_queue_manager.egg-info/top_level.txt
+django_queue_manager/migrations/0001_initial.py
 django_queue_manager/migrations/__init__.py
 django_queue_manager/utilities/__init__.py
 django_queue_manager/utilities/loggers.py

django-queue-manager/django_queue_manager/worker.py

@@ -75,9 +75,10 @@ def run(self):
         # the queue and move the task into success/failed tasks in base of successful or not execution.
         self.logger.info('Worker Thread Starts')
         while not self._stopevent.isSet():
-            if not self.worker_queue.empty():
+                task = self.worker_queue.get()
+                if task == None:
+                    break
                 try:
-                    task = self.worker_queue.get()
                     self.logger.info('Consuming Task Id: {db_id}'.format(
                         name=task.task_function_name,
                         db_id=task.db_id))
@@ -100,16 +101,15 @@ def run(self):
                     continue
 
                 finally:
-                    # In any case, it will dequeue the task form the queued tasks
-                    self.dequeue_task(task=task)
+
+                    if task:
+                        # In any case, it will dequeue the task form the queued tasks
+                        self.dequeue_task(task=task)
 
                     # Close the connection, in order to prevent (2006, 'MySQL server has gone away') timeout error
                     from django.db import connection
                     connection.close()
 
-            else:
-                # In order to respect the CPU sleeps for 50 milliseconds when the queue it's empty
-                time.sleep(0.100)
 
         self.worker_queue = None
         self.logger.warning('Worker Thread stopped, {0} tasks handled'.format(self.tasks_counter))

django-queue-manager/setup.py

@@ -9,7 +9,7 @@
 
 setup(
     name='django-queue-manager',
-    version='1.3.1',
+    version='1.3.3',
     packages=find_packages(),
     include_package_data=True,
     license='GNU GPLv3',