Function run_and_print

src/google/adk/cli/cli.py:220–234

()

    invocation_id = None

    async def run_and_print():
      nonlocal invocation_id
      async with Aclosing(
          runner.run_async(
              user_id=session.user_id,
              session_id=session.id,
              new_message=next_message,
              invocation_id=resume_invocation_id,
          )
      ) as agen:
        async for event in agen:
          collected_events.append(event)
          if getattr(event, 'invocation_id', None):
            invocation_id = event.invocation_id
          _print_event(event, jsonl=jsonl, session_id=session.id)

    try:
      if timeout: