debug code

Author: Alexey Tsitkin

auto_tasks/service.py

@@ -32,6 +32,12 @@ def register_task(self, method, queue_name=None, max_retries=None):
         func_name = method.func_name
 
         def _auto_task_wrapper_invoker(*args, **kwargs):
+            if queue_name:
+                kwargs['queue_name'] = queue_name
+
+            if max_retries:
+                kwargs['max_retries'] = max_retries
+
             _auto_task_wrapper.delay(
                 class_.__module__,
                 class_.__name__,

setup.py

@@ -6,7 +6,7 @@
 
 setup(
     name='django-eb-sqs',
-    version='1.30',
+    version='1.29',
     package_dir={'eb_sqs': 'eb_sqs'},
     include_package_data=True,
     packages=find_packages(),