fix: assign fired_triggers var

Author: radu-mocanu

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "uipath-runtime"
-version = "0.8.3"
+version = "0.8.4"
 description = "Runtime abstractions and interfaces for building agents and automation scripts in the UiPath ecosystem"
 readme = { file = "README.md", content-type = "text/markdown" }
 requires-python = ">=3.11"

src/uipath/runtime/resumable/runtime.py

@@ -115,6 +115,7 @@ async def stream(
 
         final_result: UiPathRuntimeResult | None = None
         execution_completed = False
+        fired_triggers = None
 
         while not execution_completed:
             async for event in self.delegate.stream(input, options=options):
@@ -133,14 +134,14 @@ async def stream(
                     yield suspension_result
                     execution_completed = True
 
-                # Note: when resuming a job, orchestrator deletes all triggers associated with it,
-                # thus we can resume the runtime at this point without worrying a trigger may be fired 'twice'
-                input = fired_triggers
+            # Note: when resuming a job, orchestrator deletes all triggers associated with it,
+            # thus we can resume the runtime at this point without worrying a trigger may be fired 'twice'
+            input = fired_triggers
 
-                if not options:
-                    options = UiPathStreamOptions(resume=True)
-                else:
-                    options.resume = True
+            if not options:
+                options = UiPathStreamOptions(resume=True)
+            else:
+                options.resume = True
 
     async def _restore_resume_input(
         self, input: dict[str, Any] | None