私はこのタスクを次のようなグループとして呼び出しています。
celery.group(getting_a_page.s(user, i,post) for i in range(no_of_pages))().get()
これが私の仕事です:
@task(ignore_result=True)
def getting_a_page(user,page_no,post):
print "getting a posterous page"
return True
どこが間違っているのですか?このエラーはどういう意味ですか?
編集:
エラーメッセージ:
/home/migrate/migrate/../migrate/apps/migrateuser/views.py" in start_migration
72. getting_a_page(user)
File "/home/migrate/migrate/apps/posting_app/posting.py" in posterours_get_pages_task
21. celery.group(getting_a_page.s(user, i,post) for i in range(no_of_pages))().get()
File "/usr/local/lib/python2.7/dist-packages/celery/canvas.py" in __call__
316. map(Signature.clone, self.tasks), partial_args)