async def main():
    """This test shows heartbeat monitoring.

    A warning is dispalyed when heartbeats are not received within the
    default (5 seconds) timeout.
    """
    pipeline = Pipeline([NullProcessor()])

    task = PipelineTask(pipeline, params=PipelineParams(enable_heartbeats=True))

    runner = PipelineRunner()

    await runner.run(task)
This test shows heartbeat monitoring.

    A warning is dispalyed when heartbeats are not received within the
    default (5 seconds) timeout.
    
examples/foundational/31-heartbeats.py