Workaround for bad header: Simon Young <syoung@bamfunds.com>

Snap the publish time at the start of the node: Simon Young <syoung@bamfunds.com>
Use wallclock time for perspective history: Simon Young <syoung@bamfunds.com>

Signed-off-by: Alexander Balabin <abalabin@bamfunds.com>

Author: abalabin-bamfunds

hgraph/adaptors/perspective/_perspetive_publish.py

@@ -76,6 +76,7 @@ def _publish_table_from_tsd(
     to be tuples in which case the index_col_name is expected to be a comma separated list (no spaces) of the key names
     in order. index_col_name can also include names of columns from the value in case of Frame value type.
     """
+    now = ec.now
     data = None
     if state.multi_row:
         for k in ts.removed_keys():
@@ -116,10 +117,10 @@ def _publish_table_from_tsd(
                 data = {**data, **state.create_index(data)}
             if history is not None:
                 if state.sample_row:
-                    sample = {**state.sample_row(v), **data, "time": ec.evaluation_time}
+                    sample = {**state.sample_row(v), **data, "time": now}
                     state.history.append(sample)
                 else:
-                    state.history.append({**data, "time": ec.evaluation_time})
+                    state.history.append({**data, "time": now})
 
             if state.map_index:
                 with state.index_to_id_lock:

hgraph/adaptors/sql/sql_adaptor_raw.py

@@ -87,8 +87,8 @@ def run_query(connection: SqlAdaptorConnection, id: int, query: str, queue):
             queue(tick)
         except Exception as e:
             logger.error(f"Query {id} on {path} failed: {query}")
-            time_taken = time_str((time.perf_counter_ns() - start) / 1_000_000_000)
-            logger.exception(f"Query failed after {time_taken}")
+            time_taken = (time.perf_counter_ns() - start) / 1_000_000_000
+            logger.exception(f"Query failed after {time_taken}s")
             error = {id: {"status": StreamStatus.ERROR, "status_msg": str(e)}}
             queue(error)
 
@@ -216,13 +216,13 @@ def run_query(connection: SqlAdaptorConnection, id: int, query: str, queue):
             logger.info(f"Executing query {id} on {path}:\n{query}")
             start = time.perf_counter_ns()
             r = connection.read_database(query)
-            time_taken = time_str((time.perf_counter_ns() - start) / 1_000_000_000)
-            logger.info(f"Finished executing query {id} in {time_taken}")
+            time_taken = (time.perf_counter_ns() - start) / 1_000_000_000
+            logger.info(f"Finished executing query {id} in {time_taken}s")
             tick = {id: {"status": StreamStatus.OK, "status_msg": "", "timestamp": datetime.now(UTC)}}
             queue(tick)
         except Exception as e:
             logger.error(f"Query {id} on {path} failed: {query}")
-            time_taken = time_str((time.perf_counter_ns() - start) / 1_000_000_000)
+            time_taken = (time.perf_counter_ns() - start) / 1_000_000_000
             logger.exception(f"Query failed after {time_taken}")
             error = {id: {"status": StreamStatus.ERROR, "status_msg": str(e)}}
             queue(error)

hgraph/adaptors/tornado/http_client_adaptor.py

@@ -124,7 +124,10 @@ async def handle_auth_win(response, request, client):
             final = response2.headers.get("WWW-Authenticate")
             if final is not None:
                 try:
-                    challenge = [v[len(scheme) + 1 :] for val in final.split(",") if scheme in (v := val.strip())]
+                    if scheme in final:
+                        challenge = [v[len(scheme) + 1 :] for val in final.split(",") if scheme in (v := val.strip())]
+                    else:
+                        challenge = [val.strip() for val in final.split(",")]
                     if len(challenge) > 1:
                         raise HTTPError(401, f"Received more than one {scheme} challenge from server")