just call task directly

2012-05-15 16:55:49 -04:00 · 2012-05-15 16:55:49 -04:00 · 9182b966e3
commit 9182b966e3
parent aba52c28a3
1 changed files with 1 additions and 1 deletions
--- a/oyster/scripts/signal.py
+++ b/oyster/scripts/signal.py
@ -28,7 +28,7 @@ def main():
        module, name = args.task.rsplit('.', 1)
        task = getattr(__import__(module, fromlist=[name]), name)
        for doc in docs:
-            task.apply((doc['_id'],))
+            task(doc['_id'])

    else:
        for doc in docs: