API Docs

Celery application for Invenio.

class invenio_celery.ext.InvenioCelery(app=None, **kwargs)

Invenio celery extension.

Extension initialization.

disable_queue(name)

Disable given Celery queue.

enable_queue(name)

Enable given Celery queue.

get_active_tasks()

Return a list of UUIDs of active tasks.

get_queues()

Return a list of current active Celery queues.

init_app(app, entry_point_group='invenio_celery.tasks', **kwargs)

Initialize application object.

init_config(app)

Initialize configuration.

load_entry_points()

Load tasks from entry points.

suspend_queues(active_queues, sleep_time=10.0)

Suspend Celery queues and wait for running tasks to complete.

invenio_celery.ext.celery_module_imports(sender, signal=None, **kwargs)

Load shared celery tasks.