fixes callback arguments

vedarthk · Jun 20, 2017 · 5ac1e57 · 5ac1e57
1 parent 5aef00f
commit 5ac1e57
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/async_runner/async_runner.py b/async_runner/async_runner.py
@@ -289,5 +289,6 @@ def _action_callback(action, task_id, task_fn_module, task_fn_name, queue, count
         if module_string:
             func = _import(module_string)
             return func(
-                task_id=task_id, task_fn_module=task_fn_module,
-                task_fn_name=task_fn_name, queue=queue, countdown=countdown)
+                action=action.value, task_id=task_id, task_fn_module=task_fn_module,
+                task_fn_name=task_fn_name, queue=queue, countdown=countdown,
+                args=args, kwargs=kwargs)