Merge branch 'main' into metrics-1

numaproj · Aug 7, 2023 · 36a7bfd · 36a7bfd
2 parents 1e50c93 + 5653128
commit 36a7bfd
Show file tree

Hide file tree

Showing 3 changed files with 267 additions and 203 deletions.
diff --git a/numaprom/udf/threshold.py b/numaprom/udf/threshold.py
@@ -84,8 +84,10 @@ def threshold(_: list[str], datum: Datum) -> list[tuple[str, bytes]]:
         )
         payload.set_header(Header.STATIC_INFERENCE)
         payload.set_status(Status.RUNTIME_ERROR)
-        increase_redis_conn_error(_VERTEX)
-        return orjson.dumps(payload, option=orjson.OPT_SERIALIZE_NUMPY)
+        return [
+            (TRAIN_VTX_KEY, orjson.dumps(train_payload)),
+            (POSTPROC_VTX_KEY, _get_static_thresh_payload(payload, metric_config)),
+        ]
     except Exception as ex:
         LOGGER.exception(
             "{uuid} - Unhandled exception while fetching threshold artifact, "