()
| 415 | console.print("[green]✓[/green] Heartbeat: every 30m") |
| 416 | |
| 417 | async def run(): |
| 418 | try: |
| 419 | await cron.start() |
| 420 | await heartbeat.start() |
| 421 | await asyncio.gather( |
| 422 | agent.run(), |
| 423 | channels.start_all(), |
| 424 | ) |
| 425 | except KeyboardInterrupt: |
| 426 | console.print("\nShutting down...") |
| 427 | heartbeat.stop() |
| 428 | cron.stop() |
| 429 | agent.stop() |
| 430 | await channels.stop_all() |
| 431 | |
| 432 | asyncio.run(run()) |
| 433 |