75 introspect orca results

examples/simpletrigger/simpletrigger/processor.py

@@ -1,11 +1,14 @@
 import time
+import datetime as dt
 
 from orca_python import (
     Processor,
     WindowType,
+    ValueResult,
     StructResult,
     MetadataField,
     ExecutionParams,
+    lookback,
 )
 
 proc = Processor("ml")
@@ -23,7 +26,7 @@
 )
 
 
-@proc.algorithm("MyAlgo", "1.0.0", Every30Second)
+@proc.algorithm("MyAlgo", "1.0.0", Every30Second, description="Does nothing")
 def my_algorithm(params: ExecutionParams) -> StructResult:
     """A simple algorithms that does nothing interesting"""
     route_id = params.window.metadata.get("route_id", None)
@@ -34,6 +37,33 @@ def my_algorithm(params: ExecutionParams) -> StructResult:
     return StructResult({"result": 42})
 
 
+@proc.algorithm(
+    "NewSuperDuperAlgo",
+    "2.0.0",
+    Every30Second,
+    description="Depends on other",
+    depends_on=[lookback(my_algorithm, td=dt.timedelta(days=10))],
+)
+def second_algorithm(params: ExecutionParams) -> ValueResult:
+    if params.dependencies is None:
+        raise Exception("could not get dependencies")
+    dependencyResults = params.dependencies.get_result(my_algorithm)
+
+    if dependencyResults is None:
+        return ValueResult(10)
+
+    value = 0
+    for res in dependencyResults.results:
+        if not isinstance(res.result, dict):
+            raise Exception("Bad result received")
+        _res = res.result.get("result", None)
+        if _res is None:
+            continue
+        value += _res
+
+    return ValueResult(value)
+
+
 if __name__ == "__main__":
     proc.Register()
     proc.Start()

examples/simpletrigger/simpletrigger/window.py

@@ -1,4 +1,3 @@
-import time
 import datetime as dt
 
 import schedule
@@ -24,6 +23,6 @@ def emitWindow() -> None:
 
 if __name__ == "__main__":
     emitWindow()
-    while True:
-        schedule.run_pending()
-        time.sleep(1)
+    # while True:
+    #     schedule.run_pending()
+    #     time.sleep(1)

orca_python/__init__.py

@@ -9,6 +9,7 @@
     StructResult,
     MetadataField,
     ExecutionParams,
+    lookback,
 )
 
 __all__ = [
@@ -22,4 +23,5 @@
     "ArrayResult",
     "NoneResult",
     "ExecutionParams",
+    "lookback",
 ]