fork/cellxgene-gateway
1
0
Fork 0
mirror of https://github.com/Novartis/cellxgene-gateway.git synced 2026-10-08 20:38:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

Address linter warnings

Browse Source
This commit is contained in:
Alok Saldanha
2025-11-08 10:57:50 -05:00
parent a35c6b9b1e
commit 1d1d8b4e59
1 changed files with 25 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cellxgene_gateway/gateway.py
+25 -12
View File
@@ -92,8 +92,9 @@ def _init_on_first_wsgi_request(wsgi_app):
global data_sources_initialized global data_sources_initialized
if not data_sources_initialized: if not data_sources_initialized:
with data_sources_init_lock: with data_sources_init_lock:
if not app.launchtime: if not app.extensions.get("cellxgene_gateway", {}).get("launchtime"):
app.launchtime = current_time_stamp() app.extensions.setdefault("cellxgene_gateway", {})["launchtime"] = current_time_stamp()
if not data_sources_initialized: if not data_sources_initialized:
initialize_data_sources() initialize_data_sources()
@@ -248,7 +249,7 @@ entry_lock = Lock()
def matching_source(source_name): def matching_source(source_name):
if source_name is None: if source_name is None and default_item_source is not None:
source_name = default_item_source.name source_name = default_item_source.name
matching = [i for i in item_sources if i.name == source_name] matching = [i for i in item_sources if i.name == source_name]
if len(matching) != 1: if len(matching) != 1:
@@ -295,6 +296,11 @@ def do_view(path, source_name=None):
raise CellxgeneException("User not authorized to access this data", 403) raise CellxgeneException("User not authorized to access this data", 403)
elif match.status == CacheEntryStatus.error: elif match.status == CacheEntryStatus.error:
raise ProcessException.from_cache_entry(match) raise ProcessException.from_cache_entry(match)
else:
raise CellxgeneException(
f"Unexpected cache entry status {match.status} for key {match.key.descriptor}",
500,
)
@app.route("/cache_status", methods=["GET"]) @app.route("/cache_status", methods=["GET"])
@@ -310,7 +316,7 @@ def do_GET_status():
def do_GET_status_json(): def do_GET_status_json():
return json.dumps( return json.dumps(
{ {
"launchtime": app.launchtime, "launchtime": app.extensions.get("cellxgene_gateway", {}).get("launchtime"),
"entry_list": [ "entry_list": [
{ {
"dataset": entry.key.dataset, "dataset": entry.key.dataset,
@@ -324,12 +330,21 @@ def do_GET_status_json():
} }
) )
def get_cache_key(path):
if request.args.get("source_name"):
source_name = request.args.get("source_name")
elif default_item_source:
source_name = default_item_source.name
else:
source_name = None
source = matching_source(source_name)
key = CacheKey.for_lookup(source, source.lookup(path))
return key
@app.route("/relaunch/<path:path>", methods=["GET"]) @app.route("/relaunch/<path:path>", methods=["GET"])
def do_relaunch(path): def do_relaunch(path):
source_name = request.args.get("source_name") or default_item_source.name key = get_cache_key(path)
source = matching_source(source_name)
key = CacheKey.for_lookup(source, source.lookup(path))
match = cache.check_entry(key) match = cache.check_entry(key)
if not match is None: if not match is None:
match.terminate() match.terminate()
@@ -341,9 +356,7 @@ def do_relaunch(path):
@app.route("/terminate/<path:path>", methods=["GET"]) @app.route("/terminate/<path:path>", methods=["GET"])
def do_terminate(path): def do_terminate(path):
source_name = request.args.get("source_name") or default_item_source.name key = get_cache_key(path)
source = matching_source(source_name)
key = CacheKey.for_lookup(source, source.lookup(path))
match = cache.check_entry(key) match = cache.check_entry(key)
if not match is None: if not match is None:
match.terminate() match.terminate()
@@ -365,10 +378,10 @@ def start_pruner_thread():
def launch(): def launch():
start_pruner_thread() start_pruner_thread()
app.launchtime = current_time_stamp() app.extensions.setdefault("cellxgene_gateway", {})["launchtime"] = current_time_stamp()
app.run(host="0.0.0.0", port=env.gateway_port, debug=False) app.run(host="0.0.0.0", port=env.gateway_port, debug=False)
app.launchtime = None app.extensions.setdefault("cellxgene_gateway", {})["launchtime"] = None
def main(): def main():
"""CLI entry point for Flask development server.""" """CLI entry point for Flask development server."""