Method _attempt_retry

src/google/adk/workflow/_node_runner.py:172–188

Checks if node should retry and sleeps if so.

(
      self, e: Exception, ctx: Context, attempt_count: int
  )

        attempt_count += 1

  async def _attempt_retry(
      self, e: Exception, ctx: Context, 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
    from .utils._retry_utils import _should_retry_node

    node_state = NodeState(attempt_count=attempt_count)

    if not _should_retry_node(e, self._node.retry_config, node_state):
      return False

    delay = _get_retry_delay(self._node.retry_config, node_state)

    await asyncio.sleep(delay)
    return True

  def _create_child_context(
      self,