Function run_function_async

app/plugins/worker.py:7–16

Run a function asynchronously using Celery. Plugins should use this function so that they don't have to register new Celery tasks at startup. Functions should import any required library at the top of the function body. :param {Function} a function to execute

(func, *args, **kwargs)

task = app.task

def run_function_async(func, *args, **kwargs):
    """
    Run a function asynchronously using Celery.
    Plugins should use this function so that they don't
    have to register new Celery tasks at startup. Functions
    should import any required library at the top of the function body.
    :param {Function} a function to execute
    """
    source = inspect.getsource(func)
    return eval_async.delay(source, func.__name__, *args, **kwargs)


@app.task(bind=True, time_limit=settings.WORKERS_MAX_TIME_LIMIT)