Source code for planemo.galaxy.serve

"""Abstractions for serving out development Galaxy servers."""

import contextlib
import os
import time

from planemo import (
    io,
    network_util,
)
from .config import galaxy_config
from .ephemeris_sleep import sleep
from .run import run_galaxy_command


[docs] @contextlib.contextmanager def serve(ctx, runnables=None, **kwds): if runnables is None: runnables = [] """Serve a Galaxy instance with artifacts defined by paths.""" try: with _serve(ctx, runnables, **kwds) as config: yield config except Exception as e: ctx.vlog("Problem serving Galaxy", exception=e) raise
@contextlib.contextmanager def _serve(ctx, runnables, **kwds): engine = kwds.get("engine", "galaxy") if engine == "docker_galaxy": kwds["dockerize"] = True daemon = kwds.get("daemon", False) if daemon: kwds["no_cleanup"] = True port = kwds.get("port", None) if port is None: port = network_util.get_free_port() kwds["port"] = port with galaxy_config(ctx, runnables, **kwds) as config: cmd = config.startup_command(ctx, **kwds) action = "Starting Galaxy" exit_code = run_galaxy_command( ctx, cmd, config.env, action, ) if exit_code: message = "Problem running Galaxy command [%s]." % config.log_contents io.warn(message) raise Exception(message) host = kwds.get("host", "127.0.0.1") startup_timeout = kwds.get("galaxy_startup_timeout", 900) galaxy_url = f"http://{host}:{port}" galaxy_alive = sleep(galaxy_url, verbose=ctx.verbose, timeout=startup_timeout) if not galaxy_alive: raise Exception( f"Attempted to serve Galaxy at {galaxy_url}, but it failed to start in {startup_timeout} seconds." ) config.install_workflows() if kwds.get("pid_file"): real_pid_file = config.pid_file if os.path.exists(config.pid_file): os.symlink(real_pid_file, kwds["pid_file"]) else: io.warn("Can't find Galaxy pid file [%s] to link" % real_pid_file) yield config
[docs] @contextlib.contextmanager def serve_daemon(ctx, runnables=None, **kwds): """Serve a daemonized Galaxy instance with artifacts defined by paths.""" if runnables is None: runnables = [] config = None kwds["daemon"] = True try: with serve(ctx, runnables, **kwds) as config: yield config finally: if config: if ctx.verbose: print("Galaxy Log:") print(config.log_contents) config.kill() if not kwds.get("no_cleanup", False): config.cleanup()
def sleep_for_serve(): # This is bad, do something better... for _ in range(3600 * 24): time.sleep(1) __all__ = ( "serve", "serve_daemon", )