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.