galaxy.celery package

galaxy.celery.set_thread_app(app)[source]
galaxy.celery.get_galaxy_app()[source]
galaxy.celery.build_app()[source]
galaxy.celery.get_app_properties()[source]
galaxy.celery.get_config()[source]
galaxy.celery.get_broker()[source]
galaxy.celery.get_backend()[source]
galaxy.celery.get_history_audit_table_prune_interval()[source]
galaxy.celery.get_cleanup_short_term_storage_interval()[source]
galaxy.celery.init_fork_pool()[source]
galaxy.celery.setup_worker_pool(sender=None, conf=None, instance=None, **kwargs)[source]
galaxy.celery.tear_down_pool(sig, how, exitcode, **kwargs)[source]
galaxy.celery.galaxy_task(*args, action=None, **celery_task_kwd)[source]

Submodules

galaxy.celery.tasks module

galaxy.celery.tasks.cached_create_tool_from_representation(app, raw_tool_source)[source]
galaxy.celery.tasks.is_aborted(session: galaxy_scoped_session, job_id: int)[source]
galaxy.celery.tasks.abort_when_job_stops(function: Callable, session: galaxy_scoped_session, job_id: int, *args, **kwargs)[source]