the same "mind error" applies.
you should queue the task in one function, and retrieve the result in
another (polling is the easiest way, looping is the worst idea).
On Wednesday, May 28, 2014 10:36:18 PM UTC+2, Cory wrote:
>
> Thanks Niphlod and good point. I am using it with LOAD() so im still
> maintaining async, I just need to know when its ready. This helped a lot, I
> did not try db.commit before and did not realize. Thanks again!
>
> On Wednesday, May 28, 2014 1:23:16 PM UTC-7, Niphlod wrote:
>>
>> Hi.
>> There must be something wrong with what you expect.
>> The scheduler is an ASYNC process, meaning that - usually - trying to
>> fetch the result in the same request that queued it is a wrong idea in so
>> many ways that should be obvious.
>> That being said, this works without any issues.
>>
>> models/scheduler.py
>> def add(a,b):
>> return a + b
>>
>> from gluon.scheduler import Scheduler
>> mysched = Scheduler(db)
>>
>> controllers/default.py
>>
>> def index():
>> thetask = mysched.queue_task('add', pargs=[3,4])
>> db.commit() #otherwise the scheduler process can't see it
>> result = None
>> task_id = None
>> while 1:
>> intermediate = mysched.task_status(thetask.uuid, output=True)
>> if intermediate.result:
>> result = intermediate.result
>> task_id = thetask.uuid
>> break
>> time.sleep(1)
>> return dict(res=result, task_id=task_id)
>>
>> On Wednesday, May 28, 2014 5:55:20 PM UTC+2, Cory wrote:
>>>
>>> Hi,
>>> I am having trouble getting the run_result after web2py has finished a
>>> task using web2py's scheduler.
>>> The code below is what I am using. The trouble I am having is grabbing
>>> the result once the result is
>>> ready. Do any of you know how to get the run_result from a task once the
>>> task has finished? right now
>>> when I try to get the run_result I get a "None" value because I try to
>>> get the result before it is ready.
>>> The task can take a couple of seconds to finish. I have tried many
>>> different ways to get the result once
>>> it is ready. For instance, creating a while loop that checks to see if
>>> the task status has changed to
>>> "completed" then grab the result, but that does not work. Any ideas? I
>>> have been stuck on this far too long.
>>>
>>> task2 = sched.queue_task('upsQuote', pargs = [session.Weight,
>>> session.OrigZip, session.DestZip], timeout = 5, start_time = request.now)
>>> #add the task
>>> task_status2 = sched.task_status(task2.uuid, output=True) #
>>> get the task status
>>> result2 = task_status2.scheduler_run.run_result
>>> # get the result from the finished task
>>>
>>>
>>>
--
Resources:
- http://web2py.com
- http://web2py.com/book (Documentation)
- http://github.com/web2py/web2py (Source code)
- https://code.google.com/p/web2py/issues/list (Report Issues)
---
You received this message because you are subscribed to the Google Groups
"web2py-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
For more options, visit https://groups.google.com/d/optout.
