refactor: Clean up unused variables and arguments in adk/workflow

- Remove unused local variable `target_state` in `_workflow.py`.
- Remove unused `ctx` argument from `NodeRunner._attempt_retry`.
- Remove unused `node_path` and `curr_parent_ctx` arguments from `check_interception` utility function.

Co-authored-by: Shangjie Chen <deanchen@google.com>
PiperOrigin-RevId: 941198065

Author: DeanChensj

src/google/adk/workflow/_dynamic_node_scheduler.py

@@ -266,11 +266,9 @@ async def _check_existing_run(
 
     # Delegate replay and same-turn interception check to ReplayInterceptor.
     result = check_interception(
-        node_path=node_path,
         node=curr_node,
         recovered=run.recovered_state,
         current_run=run,
-        curr_parent_ctx=curr_parent_ctx,
     )
 
     if not result.should_run:

src/google/adk/workflow/_node_runner.py

@@ -157,7 +157,7 @@ async def run(
         )
         await self._enqueue_event(error_event, ctx)
 
-        if not await self._attempt_retry(e, ctx, attempt_count):
+        if not await self._attempt_retry(e, attempt_count):
           ctx._error = e
           ctx._error_node_path = ctx.node_path
           logger.debug("node %s end.", ctx.node_path)
@@ -169,9 +169,7 @@ async def run(
         )
         attempt_count += 1
 
-  async def _attempt_retry(
-      self, e: Exception, ctx: Context, attempt_count: int
-  ) -> bool:
+  async def _attempt_retry(self, e: Exception, attempt_count: int) -> bool:
     """Checks if node should retry and sleeps if so."""
     from ._node_state import NodeState
     from .utils._retry_utils import _get_retry_delay

src/google/adk/workflow/_workflow.py

@@ -555,10 +555,8 @@ def _start_node_task(
       recovered = loop_state.recovered_executions[key]
 
       result = check_interception(
-          node_path=f'{ctx.node_path}/{node_name}@{run_id}',
           node=node,
           recovered=recovered,
-          curr_parent_ctx=ctx,
       )
 
       if not result.should_run:
@@ -688,7 +686,6 @@ def _buffer_downstream_triggers(
     use_sub_branch = len(next_nodes) > 1
     for target_name in next_nodes:
       target_node = self._get_static_node_by_name(target_name)
-      target_state = loop_state.nodes.get(target_name)
 
       if target_node._requires_all_predecessors:
         # Wait for all predecessors

src/google/adk/workflow/utils/_replay_interceptor.py

@@ -56,11 +56,9 @@ class InterceptionResult:
 
 def check_interception(
     *,
-    node_path: str,
     node: BaseNode,
     recovered: _ChildScanState | None = None,
     current_run: DynamicNodeRun | None = None,
-    curr_parent_ctx: Context,
 ) -> InterceptionResult:
   """Determine if a node execution should be intercepted based on history."""
   from .._workflow import Workflow  # pylint: disable=g-import-not-at-top

tests/unittests/workflow/utils/test_replay_interceptor.py

@@ -18,9 +18,6 @@
 replay interception.
 """
 
-from unittest.mock import MagicMock
-
-from google.adk.agents.context import Context
 from google.adk.workflow._base_node import BaseNode
 from google.adk.workflow._dynamic_node_scheduler import DynamicNodeRun
 from google.adk.workflow._node_state import NodeState
@@ -30,13 +27,6 @@
 import pytest
 
 
-def _make_parent_ctx():
-  ctx = MagicMock(spec=Context)
-  ctx._invocation_context = MagicMock()
-  ctx.resume_inputs = {}
-  return ctx
-
-
 def test_same_turn_completed():
   """Same-turn completed run intercepts and returns cached output."""
   # Given a same-turn completed run
@@ -45,14 +35,11 @@ def test_same_turn_completed():
       output='cached-out',
       transfer_to_agent='target-agent',
   )
-  ctx = _make_parent_ctx()
 
   # When checked
   result = check_interception(
-      node_path='wf/node@1',
       node=BaseNode(name='node'),
       current_run=run,
-      curr_parent_ctx=ctx,
   )
 
   # Then it intercepts with cached results
@@ -67,14 +54,11 @@ def test_same_turn_waiting():
   run = DynamicNodeRun(
       state=NodeState(status=NodeStatus.WAITING, interrupts=['fc-1']),
   )
-  ctx = _make_parent_ctx()
 
   # When checked
   result = check_interception(
-      node_path='wf/node@1',
       node=BaseNode(name='node'),
       current_run=run,
-      curr_parent_ctx=ctx,
   )
 
   # Then it intercepts and keeps waiting
@@ -91,14 +75,11 @@ def test_cross_turn_unresolved_interrupts_no_rerun():
       resolved_ids={'fc-1'},
   )
   node = BaseNode(name='node', rerun_on_resume=False)
-  ctx = _make_parent_ctx()
 
   # When checked
   result = check_interception(
-      node_path='wf/node@1',
       node=node,
       recovered=recovered,
-      curr_parent_ctx=ctx,
   )
 
   # Then it stays waiting on unresolved interrupts
@@ -116,14 +97,11 @@ def test_cross_turn_unresolved_interrupts_rerun():
       resolved_responses={'fc-1': 'ans'},
   )
   node = BaseNode(name='node', rerun_on_resume=True)
-  ctx = _make_parent_ctx()
 
   # When checked
   result = check_interception(
-      node_path='wf/node@1',
       node=node,
       recovered=recovered,
-      curr_parent_ctx=ctx,
   )
 
   # Then it reruns with partial resolved inputs
@@ -140,14 +118,11 @@ def test_cross_turn_completed():
       route='route-a',
   )
   node = BaseNode(name='node')
-  ctx = _make_parent_ctx()
 
   # When checked
   result = check_interception(
-      node_path='wf/node@1',
       node=node,
       recovered=recovered,
-      curr_parent_ctx=ctx,
   )
 
   # Then it fast-forwards with cached output and route
@@ -166,17 +141,11 @@ def test_cross_turn_all_resolved_no_rerun():
       resolved_responses={'fc-1': 'ans'},
   )
   node = BaseNode(name='node', rerun_on_resume=False)
-  ctx = _make_parent_ctx()
-  ctx.resume_inputs = {
-      'fc-1': {'result': 'ans'}
-  }  # Simulate FunctionResponse dict
 
   # When checked
   result = check_interception(
-      node_path='wf/node@1',
       node=node,
       recovered=recovered,
-      curr_parent_ctx=ctx,
   )
 
   # Then it auto-completes
@@ -194,14 +163,11 @@ def test_cross_turn_all_resolved_rerun():
       resolved_responses={'fc-1': 'ans'},
   )
   node = BaseNode(name='node', rerun_on_resume=True)
-  ctx = _make_parent_ctx()
 
   # When checked
   result = check_interception(
-      node_path='wf/node@1',
       node=node,
       recovered=recovered,
-      curr_parent_ctx=ctx,
   )
 
   # Then it reruns