call a celery task within a Django view method?

Question

I have two Pythonapplications 'frontend' and 'fv'. in my fv app is my tasks.py file and in my frontend app is my views.py file to render my views.

Now I have a view where I can choose some parameters get these with request.POST. and now I'd like to call a a task method FunctionRDynamic and pass the parameters from my view form.

Method in views.py:

if request.method == 'POST':
        form1 = dataproviderInstrumentForm(request.POST)
        form2 = dynamicTimeseriesForm(request.POST)

        if form1.is_valid() or form2.is_valid(): 
            filters = form2.cleaned_data['filter']
            estimator = form2.cleaned_data['estimator']
            windowSize = form2.cleaned_data['windowSize']

            FunctionRDynamic.delay(estimator, windowSize, timeseries)

FunctionRDynamic is my method in the tasks.py file in the oder application, but this method will not execute.

For my tasks I use celery. All is written in Python and I use Django as mvc framework.

Does anyone have suggestions?

Joyfulgrind · Accepted Answer · 2013-08-27 11:53:38Z

16

From what I have understood here's the solution. While defining celery tasks do this:

@celery.task
def file_transfer(password, source12, destination):
    # Do stuffs with paramters

Now in your views.py do this:

def test(View):
    # Get the data from post
    if request.method == 'POST':
        name = request.POST['name']
        # And get all the variable you need for the tasks

        # Now call the task like this
        file_transfer.delay(name, 'test', 'test')

edited Aug 27, 2013 at 11:53

answered Aug 27, 2013 at 11:43

Joyfulgrind

2,8568 gold badges37 silver badges44 bronze badges

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

4 Comments

user2412771 Over a year ago

thx for the fast answer, if i call the task without .delay - as your solution, i get a "Unable to connect" error in my browser and i lost the connection.

Joyfulgrind Over a year ago

Yes, you have to use task_name.delay. Sorry for the typo.

Joyfulgrind Over a year ago

Two questions: Do you have celery running and do you have message transfer backend setup? Run the celery in DEBUG mode: ./manage.py celeryd -lDEBUG and tell me what error do you see.

user2412771 Over a year ago

it was my fault, because i haven't started the workers. thx for your solution.

Collectives™ on Stack Overflow

call a celery task within a Django view method?

1 Answer 1

4 Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

4 Comments

Your Answer

Sign up or log in

Post as a guest

Related