chore(tasks): change apply_async parameters

Author: duanhongyi

rootfs/tasks/task.py

@@ -44,14 +44,14 @@ def register_task(*args, **kwargs):
     return register_task
 
 
-def apply_async(target, delay=0, callback=None, *args, **kwargs):
+def apply_async(target, delay=0, callback=None, args=(), kwargs=None):
     target_id = "%s.%s" % (target.__module__, target.__name__)
     if target_id not in TASKS:
         raise NotImplemented("This task is not registered.")
     message = json.dumps({
         "target_id": target_id,
         "args": args,
-        "kwargs": kwargs
+        "kwargs": {} if kwargs == None else kwargs
     }).encode("utf-8")
     if delay <= 0:
         NSQD_WRITER.pub(NSQ_TOPIC, message, callback=callback)

rootfs/tasks/tests/test_task.py

@@ -27,12 +27,12 @@ def t2(t):
             self.assertEqual(time.time() - t > 3, True)
 
         def callback(addr, msg):
-            self.assertEqual(msg==b'OK', True)
+            self.assertEqual(msg == b'OK', True)
 
         threading.Thread(
             target=tornado.ioloop.IOLoop.current().start).start()
         time.sleep(3)
-        apply_async(t1, callback=callback, name="hello", value="word")
-        apply_async(t2, callback=callback, delay=3000, t=time.time())
+        apply_async(t1, callback=callback, args=("hello", "word"))
+        apply_async(t2, callback=callback, delay=3000, args=(time.time(), ))
         time.sleep(12)
         tornado.ioloop.IOLoop.current().stop()