mode-streaming

import asyncio from mode import Service, Worker class MyService(Service): async def on_start(self) -> None: print("MyService started!") self.add_background_task(self.my_periodic_task) @Service.timer(1.0) async def my_periodic_task(self) -> None: print("Periodic task running...") async def on_stop(self) -> None: print("MyService stopped.") async def main(): service = MyService() worker = Worker(service, loglevel="info") # In a real application, you'd execute from command line # For quickstart, manually manage lifecycle (or use execute_from_commandline) try: await worker.start() await asyncio.sleep(3) finally: await worker.stop() if __name__ == '__main__': asyncio.run(main())