An example trigger function with asyncio in python

asyncio.py

import asyncio
async def trigger(delay):
    while True:
        print("Triggered telemetry generation")
        await asyncio.sleep(delay)
async def main(delay, duration):
    task = asyncio.create_task(trigger(delay))
    loop = asyncio.get_event_loop()
    loop.call_later(duration, task.cancel)
    try:
        await task
    except asyncio.CancelledError:
        pass
asyncio.run(main(1, 5))