()
| 35 | return result |
| 36 | |
| 37 | def run(): |
| 38 | loop_for_thread = asyncio.new_event_loop() |
| 39 | try: |
| 40 | asyncio.set_event_loop(loop_for_thread) |
| 41 | return asyncio.run(arun()) |
| 42 | finally: |
| 43 | loop_for_thread.close() |
| 44 | |
| 45 | if getattr(EXECUTOR, '_shutdown', False): |
| 46 | result = run() |
no test coverage detected