Warning

This document is for an in-development version of Galaxy. You can alternatively view this page in the latest release if it exists or view the top of the latest release's documentation.

galaxy.web.stack package

Web application stack operations

class galaxy.web.stack.ApplicationStackLogFilter(name='')

Bases: logging.Filter

filter(record)

class galaxy.web.stack.UWSGILogFilter(name='')

Bases: logging.Filter

filter(record)

class galaxy.web.stack.ApplicationStack(app=None, config=None)

Bases: object

name = None

prohibited_middleware = frozenset([])

transport_class

alias of galaxy.web.stack.transport.ApplicationStackTransport

log_filter_class

alias of ApplicationStackLogFilter

log_format = '%(name)s %(levelname)s %(asctime)s %(message)s'

server_name_template = '{server_name}'

default_app_name = 'main'

classmethod log_filter()

classmethod get_app_kwds(config_section, app_name=None, for_paste_app=False)

classmethod register_postfork_function(f, *args, **kwargs)

__init__(app=None, config=None)

init_job_handling(job_config)

Automatically add pools as handlers if they are named per predefined names and there is not an explicit job handler assignment configuration.

Also automatically set the preferred assignment method if pool handlers are found and an assignment method is not explicitly configured by the administrator.

init_late_prefork()

log_startup()

start()

allowed_middleware(middleware)

workers()

pool_name

configured_pools

has_base_pool(pool_name)

has_pool(pool_name)

in_pool(pool_name)

pool_members(pool_name)

facts

set_postfork_server_name(app)

register_message_handler(func, name=None)

deregister_message_handler(func=None, name=None)

send_message(dest, msg=None, target=None, params=None, **kwargs)

shutdown()

class galaxy.web.stack.MessageApplicationStack(app=None, config=None)

Bases: galaxy.web.stack.ApplicationStack

__init__(app=None, config=None)

init_late_prefork()

start()

register_message_handler(func, name=None)

deregister_message_handler(func=None, name=None)

send_message(dest, msg=None, target=None, params=None, **kwargs)

shutdown()

class galaxy.web.stack.UWSGIApplicationStack(app=None, config=None)

Bases: galaxy.web.stack.MessageApplicationStack

Interface to the uWSGI application stack. Supports running additional webless Galaxy workers as mules. Mules must be farmed to be communicable via uWSGI mule messaging, unfarmed mules are not supported.

Note that mules will use this as their stack class even though they start with the “webless” loading point.

name = 'uWSGI'

prohibited_middleware = frozenset(['EvalException', 'wrap_in_static'])

transport_class

alias of galaxy.web.stack.transport.UWSGIFarmMessageTransport

log_filter_class

alias of UWSGILogFilter

log_format = '%(name)s %(levelname)s %(asctime)s [p:%(process)s,w:%(worker_id)s,m:%(mule_id)s] [%(threadName)s] %(message)s'

server_name_template = '{server_name}.{pool_name}.{instance_id}'

postfork_functions = []

localhost_addrs = ('127.0.0.1', '[::1]')

bind_all_addrs = ('', '0.0.0.0', '[::]')

classmethod get_app_kwds(config_section, app_name=None)

classmethod register_postfork_function(f, *args, **kwargs)

__init__(app=None, config=None)

configured_pools

instance_id

log_startup()

start()

in_pool(pool_name)

pool_members(pool_name)

workers()

facts

shutdown()

class galaxy.web.stack.PasteApplicationStack(app=None, config=None)

Bases: galaxy.web.stack.ApplicationStack

name = 'Python Paste'

class galaxy.web.stack.WeblessApplicationStack(app=None, config=None)

Bases: galaxy.web.stack.ApplicationStack

name = 'Webless'

__init__(app=None, config=None)

configured_pools

in_pool(pool_name)

pool_members(pool_name)

galaxy.web.stack.application_stack_class()

Returns the correct ApplicationStack class for the stack under which this Galaxy process is running.

galaxy.web.stack.application_stack_instance(app=None, config=None)

galaxy.web.stack.application_stack_log_filter()

galaxy.web.stack.application_stack_log_formatter()

galaxy.web.stack.register_postfork_function(f, *args, **kwargs)

galaxy.web.stack.get_app_kwds(config_section, app_name=None)

galaxy.web.stack.get_stack_facts(config=None)

Submodules

galaxy.web.stack.message module

Web Application Stack worker messaging

class galaxy.web.stack.message.ApplicationStackMessageDispatcher

Bases: object

__init__()

register_func(func, name=None)

deregister_func(func=None, name=None)

handler_count

dispatch(msg_str)

class galaxy.web.stack.message.ApplicationStackMessage(target=None, **kwargs)

Bases: dict

default_handler = None

__init__(target=None, **kwargs)

validate()

encode()

bind_default_handler(obj, name)

Bind the default handler method to obj as attribute name.

This could also be implemented as a mixin class.

target

set_target

class galaxy.web.stack.message.ParamMessage(target=None, params=None, **kwargs)

Bases: galaxy.web.stack.message.ApplicationStackMessage

__init__(target=None, params=None, **kwargs)

validate()

params

set_params

class galaxy.web.stack.message.TaskMessage(target=None, params=None, **kwargs)

Bases: galaxy.web.stack.message.ParamMessage

static default_handler(msg)

Can be bound to an instance of any class that has message handling methods named like _handle_{task}_method

task

class galaxy.web.stack.message.JobHandlerMessage(target=None, params=None, **kwargs)

Bases: galaxy.web.stack.message.TaskMessage

target = 'job_handler'

class galaxy.web.stack.message.WorkflowSchedulingMessage(target=None, params=None, **kwargs)

Bases: galaxy.web.stack.message.TaskMessage

target = 'workflow_scheduling'

galaxy.web.stack.message.decode(msg_str)

galaxy.web.stack.transport module

Web application stack operations

class galaxy.web.stack.transport.ApplicationStackTransport(app, stack, dispatcher=None)

Bases: object

SHUTDOWN_MSG = '__SHUTDOWN__'

__init__(app, stack, dispatcher=None)

Pre-fork initialization.

init_late_prefork()

start_if_needed()

stop_if_unneeded()

start()

Post-fork initialization.

send_message(msg, dest)

shutdown()

class galaxy.web.stack.transport.UWSGIFarmMessageTransport(app, stack, dispatcher=None)

Bases: galaxy.web.stack.transport.ApplicationStackTransport

Communication via uWSGI Mule Farm messages. Communication is unidirectional (workers -> mules).

init_late_prefork()

__init__(app, stack, dispatcher=None)

start()

Post-fork initialization.

This is mainly done here for the future possibility that we’ll be able to run mules post-fork without exec()ing. In a programmed mule it could be done at __init__ time.

shutdown()

send_message(msg, dest)