galaxy.celery package

class galaxy.celery.GalaxyCelery(*args, **kwargs)[source]

Bases: Celery

fork_pool: ProcessPool
__init__(*args, **kwargs)[source]
gen_task_name(name, module)[source]
trim_module_name(module)[source]

Drop “celery.tasks” infix for less verbose task names: - galaxy.celery.tasks.do_foo >> galaxy.do_foo - galaxy.celery.tasks.subtasks.do_fuz >> galaxy.subtasks.do_fuz

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.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]
galaxy.celery.init_celery_app()[source]
galaxy.celery.config_celery_app(config, celery_app)[source]
galaxy.celery.setup_periodic_tasks(config, celery_app)[source]

Submodules

galaxy.celery.tasks module

galaxy.celery.tasks.setup_data_table_manager(app)[source]
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, **kwargs) → Any[source]