Nivel 110: demo_level110.py

Este es el nivel 110 del tour de aprendizaje.

Código Fuente

"""
DEMO LEVEL 110: Wsqlite Async
-------------------------------
Adds: Wsqlite con PipelineAsync.
Continues: L109.

DIAGRAM:
PipelineAsync + Wsqlite
"""

import asyncio

from wpipe import PipelineAsync
from wpipe.sqlite import Wsqlite

async def proceso(data):
    return {"ok": True}

async def main():
    print(">>> Wsqlite + async...")

    db = "output/async110.db"
    pipe = PipelineAsync(pipeline_name="viaje_l110", verbose=True, tracking_db=db, show_progress=True)
    pipe.set_steps([proceso])
    await pipe.run({})

    with Wsqlite(db_name=db) as wdb:
        wdb.details = {"async": "test"}
        print("✅ Async + Wsqlite")

if __name__ == "__main__":
    asyncio.run(main())

Resultado de Ejecución

>>> Wsqlite + async...
[ASYNC STATUS] PIPE-66AA2B78: COMPLETED ✅ Async + Wsqlite

¡RECLAMA TU LOGRO!

Introduce tu nombre para desbloquear tu certificado oficial.

Certificado de Misión

WPipe Engine Certification • Misión 4

Se otorga con honor a:

---

Con el rango oficial de:

Arquitecto WPipe Gold

EMITIDO EL: --/--/----
ID: WP-110-ARQ-GOLD
WISROVI SUITE • WISROVI.DEV
Oficial Product: wpipe.wisrovi.dev

⚡

CONTINUAR ➡️