(
runner: InMemoryRunner,
telemetry_config: Optional[TelemetryConfig],
)
| 809 | tenant_off = _make_test_runner('tenant_off') |
| 810 | |
| 811 | async def _run( |
| 812 | runner: InMemoryRunner, |
| 813 | telemetry_config: Optional[TelemetryConfig], |
| 814 | ) -> None: |
| 815 | session = await runner.runner.session_service.create_session( |
| 816 | app_name=runner.app_name, user_id='test_user' |
| 817 | ) |
| 818 | async for _ in runner.runner.run_async( |
| 819 | user_id=session.user_id, |
| 820 | session_id=session.id, |
| 821 | new_message=UserContent('hi'), |
| 822 | run_config=RunConfig(telemetry=telemetry_config), |
| 823 | ): |
| 824 | pass |
| 825 | |
| 826 | await asyncio.gather( |
| 827 | _run( |
no test coverage detected