graphai.celery.common.celery_config module

graphai.celery.common.celery_config.route_task(name, args, kwargs, options, task=None, **kw)

class graphai.celery.common.celery_config.BaseConfig

Bases: object

class graphai.celery.common.celery_config.DevelopmentConfig

Bases: BaseConfig

graphai.celery.common.celery_config.get_settings()

graphai.celery.common.celery_config.create_celery()

Creates a celery app with default settings :returns: Celery app object

graphai.celery.common.celery_config.get_celery_task(task_id)

Returns results for the task with the provided task id :param task_id: task id

Returns:

AsyncResult object that contains task id, name, status, and results

graphai.celery.common.celery_config.get_task_info(task_id, task_results=None)

return task info for the given task_id