API Docs

Celery application for Invenio.

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

Invenio celery extension.

Extension initialization.

disable_queue(name)[source]

Disable given Celery queue.

enable_queue(name)[source]

Enable given Celery queue.

get_active_tasks()[source]

Return a list of UUIDs of active tasks.

get_queues()[source]

Return a list of current active Celery queues.

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

Initialize application object.

init_config(app)[source]

Initialize configuration.

load_entry_points()[source]

Load tasks from entry points.

suspend_queues(active_queues, sleep_time=10.0)[source]

Suspend Celery queues and wait for running tasks to complete.

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

Load shared celery tasks.