瀏覽代碼

Fix to also grab timeout from configuration

Arkadiusz Ryś 2 年之前
父節點
當前提交
9017de9778
共有 2 個文件被更改,包括 3 次插入3 次删除
  1. 2 2
      spendpoint/bridge.py
  2. 1 1
      spendpoint/service.py

+ 2 - 2
spendpoint/bridge.py

@@ -7,7 +7,7 @@ from typing import Union
 arklog.set_config_logging()
 
 
-def fetch_outliers(file_name: str, column: Union[str, int], iri: str, outlier_service_url: str) -> Graph:
+def fetch_outliers(file_name: str, column: Union[str, int], iri: str, outlier_service_url: str, timeout: int) -> Graph:
     """"""
     try:
         column = column if isinstance(column, int) else int(column)
@@ -16,7 +16,7 @@ def fetch_outliers(file_name: str, column: Union[str, int], iri: str, outlier_se
         raise
     parameters = {"iri": iri, "column" : column, "file" : file_name}
     try:
-        outliers_result = requests.post(outlier_service_url, json=parameters, timeout=60)
+        outliers_result = requests.post(outlier_service_url, json=parameters, timeout=timeout)
         outliers_result.raise_for_status()
     except requests.exceptions.InvalidSchema as e:
         logging.error(f"Invalid schema for '{outlier_service_url}'.")

+ 1 - 1
spendpoint/service.py

@@ -47,7 +47,7 @@ def outlier_service(query_results, ctx, part, eval_part, service_configuration):
     column = str(_eval(part.expr.expr[1], eval_part.forget(ctx, _except=part.expr._vars)))
     iri = str(_eval(part.expr.expr[2], eval_part.forget(ctx, _except=part.expr._vars)))
     logging.info(f"Looking for outlier in '{file_name}' at column '{column}' for '{iri}'.")
-    outlier_graph = fetch_outliers(file_name, column, iri, service_configuration.endpoint)
+    outlier_graph = fetch_outliers(file_name, column, iri, service_configuration.endpoint, service_configuration.timeout)
     for stmt in outlier_graph:
         query_results.append(eval_part.merge({
             part.var: stmt[0],