celery python object methods

Question

I am trying to get celery tasks wrapper around a python object method. Like:

 class A:
      @task
      def test_task(self,args):
        print "BLah..test"

   def main():
     a= A()
     args = {}
     a.test_task(args)

Now this fails with error test_task takes atleast 2 arguments (1 given). My understanding is the self object is not getting passed. Why is this so? and how do i work around this?

Update: It really was my lack of understanding of celery. the @task decorator is just to add/handle the celery task related parameters. it doesn't automatically make every call to the function a celery task. the function must be called as a.test_task.delay(args).. therein the problem...

asksol · Accepted Answer · 2012-07-29 16:43:06Z

4

Since version 3.0 Celery now supports using methods as tasks: http://docs.celeryproject.org/en/latest/reference/celery.contrib.methods.html

answered Jul 29, 2012 at 16:43

asksol

19.6k5 gold badges67 silver badges69 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

mikenerone Over a year ago

Not anymore since 2014-10-10. Apparently it was too buggy. github.com/celery/celery/commit/…

demalexx · Accepted Answer · 2012-01-13 08:37:17Z

0

Do you need to have test_task as method? Will simple function work? Or could you use static method? BTW, your main function doesn't use celery to execute test_task, it runs it as simple method.

answered Jan 13, 2012 at 8:37

demalexx

4,7692 gold badges33 silver badges34 bronze badges

Collectives™ on Stack Overflow

celery python object methods

2 Answers 2

1 Comment

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

1 Comment

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related