Nivel 93: demo_level93.py

Este es el nivel 93 del tour de aprendizaje.

ACTIVAR MODO INTERACTIVO

Código Fuente

"""
DEMO LEVEL 93: TaskTimer Async
--------------------------
Adds: TaskTimer con PipelineAsync.
Continues: L92.

DIAGRAM:
TaskTimer + PipelineAsync
"""

import asyncio

from wpipe import PipelineAsync, TaskTimer

async def task(data):
    print("⚡ Tarea async...")
    await asyncio.sleep(0.05)
    return {"ok": True}

async def main():
    with TaskTimer("async93", timeout_seconds=1) as timer:
        pipe = PipelineAsync(pipeline_name="viaje_l93", verbose=True)
        pipe.set_steps([task])
        await pipe.run({})

    print(f"\n⏱️ Tiempo: {timer.elapsed_seconds:.3f}s")

if __name__ == "__main__":
    print(">>> TaskTimer async...")
    asyncio.run(main())

Resultado de Ejecución

---

>>> TaskTimer async...
⚡ Tarea async...

⏱️ Tiempo: 0.050s