Massimo:
For instance, I created a method that returns the progress of the task
that I am running
I guess my questions could collapse into this example:
Consider,
in a db file
def plugin_run(plugin, **kw):
plugin_obj = load_plugin(plugin, **kw)
plugin_obj.start()
return plugin_obj.report() #this shall be a dictionary for
appearing in results properly
myscheduler = Scheduler(db_tasks, dict(plugin_run=plugin_run))
Eventually that plugin_obj will be picked up by a worker...
now, that it is running it is taking a lot of time and I wanted to do
something like..
from db_scheduler_worker where it is running task with
task_name="demo"
call "plugin_obj.progress()" defined inside
On Feb 10, 5:39 pm, Massimo Di Pierro <
massimo.dipie...@gmail.com>
wrote: