mirror of
https://github.com/galaxyproject/galaxy.git
synced 2026-09-24 16:30:27 +08:00
Automated merge.
This commit is contained in:
@@ -548,6 +548,9 @@ nglims_config_file = tool-data/nglims.yaml
|
||||
# Enable verbose debugging of Galaxy-managed dynamic proxy.
|
||||
#dynamic_proxy_debug=False
|
||||
|
||||
# The dynamic proxy is proxied by an external proxy (e.g. apache frontend to nodejs to wrap connections in SSL)
|
||||
#dynamic_proxy_external_proxy=False
|
||||
|
||||
# -- Logging and Debugging
|
||||
|
||||
# Verbosity of console log messages. Acceptable values can be found here:
|
||||
|
||||
@@ -388,6 +388,7 @@ class Configuration( object ):
|
||||
self.dynamic_proxy_debug = string_as_bool( kwargs.get( "dynamic_proxy_debug", "False" ) )
|
||||
self.dynamic_proxy_bind_port = int( kwargs.get( "dynamic_proxy_bind_port", "8800" ) )
|
||||
self.dynamic_proxy_bind_ip = kwargs.get( "dynamic_proxy_bind_ip", "0.0.0.0" )
|
||||
self.dynamic_proxy_external_proxy = string_as_bool( kwargs.get( "dynamic_proxy_external_proxy", "False" ) )
|
||||
|
||||
# Default chunk size for chunkable datatypes -- 64k
|
||||
self.display_chunk_size = int( kwargs.get( 'display_chunk_size', 65536) )
|
||||
|
||||
@@ -17,7 +17,7 @@ SECURE_COOKIE = "galaxysession"
|
||||
class ProxyManager(object):
|
||||
|
||||
def __init__( self, config ):
|
||||
for option in [ "manage_dynamic_proxy", "dynamic_proxy_bind_port", "dynamic_proxy_bind_ip", "dynamic_proxy_debug" ]:
|
||||
for option in [ "manage_dynamic_proxy", "dynamic_proxy_bind_port", "dynamic_proxy_bind_ip", "dynamic_proxy_debug", "dynamic_proxy_external_proxy" ]:
|
||||
setattr( self, option, getattr( config, option ) )
|
||||
self.launch_by = "node" # TODO: Support docker
|
||||
if self.manage_dynamic_proxy:
|
||||
@@ -43,7 +43,10 @@ class ProxyManager(object):
|
||||
if ':' in host:
|
||||
host = host[0:host.index(':')]
|
||||
scheme = trans.request.scheme
|
||||
proxy_url = '%s://%s:%d' % (scheme, host, self.dynamic_proxy_bind_port)
|
||||
if not self.dynamic_proxy_external_proxy:
|
||||
proxy_url = '%s://%s:%d' % (scheme, host, self.dynamic_proxy_bind_port)
|
||||
else:
|
||||
proxy_url = '%s://%s' % (scheme, host)
|
||||
return {
|
||||
'proxy_url': proxy_url,
|
||||
'proxied_port': proxy_requests.port,
|
||||
|
||||
@@ -118,8 +118,9 @@ class GalaxyInteractorApi( object ):
|
||||
def wait_for_job( self, job_id, maxseconds ):
|
||||
self.twill_test_case.wait_for( lambda: not self.__job_ready( job_id ), maxseconds=maxseconds)
|
||||
|
||||
def get_job_stdio( self, job_id, stream ):
|
||||
def get_job_stdio( self, job_id ):
|
||||
job_stdio = self.__get_job_stdio( job_id ).json()
|
||||
return job_stdio
|
||||
|
||||
def __get_job( self, job_id ):
|
||||
return self._get( 'jobs/%s' % job_id )
|
||||
|
||||
Reference in New Issue
Block a user