Update version

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "tensorlake"
-version = "0.2.42"
+version = "0.2.43"
 description = "Tensorlake SDK for Document Ingestion API and Serverless Workflows"
 readme = "README.md"
 authors = ["Tensorlake Inc. <[email protected]>"]
@@ -40,7 +40,7 @@ parameterized = "^0.9.0"
 respx = "^0.22.0"
 psutil = "^7.0.0"
 isort = "^6.0.1"
-pre-commit = "^4.2.0"
+pre-commit = "^4.3.0"
 
 [tool.poetry.plugins."poetry.command"]
 postinstall = "scripts:install_deps"

tests/workflows_sdk/test_graph_behaviors.py

@@ -953,5 +953,29 @@ def test_stream_progress(self, is_remote):
                 break
 
 
+    @parameterized.parameterized.expand([(True)])
+    def test_stream_progress(self, is_remote):
+        graph = Graph(
+            name=test_graph_name(self),
+            description="test",
+            start_node=return_multiple_values_json,
+        )
+        graph.add_edge(return_multiple_values_json, sum_multiple_values_json)
+        graph = remote_or_local_graph(
+            graph,
+            is_remote,
+        )
+        request_stream = graph.stream(x=1)
+        invocation_id = None
+        for event in request_stream:
+            if event.event_name == "RequestStarted":
+                invocation_id = event.payload.request_id
+            if event.event_name == "RequestFinished":
+                output = graph.get_output(invocation_id, "sum_multiple_values_json")
+                self.assertEqual(len(output), 1)
+                self.assertEqual(output[0], 6)
+                break
+
+
 if __name__ == "__main__":
     unittest.main()