Async API

"""
Async pairs — `aXxx` for every method.

Every public Transformation method has an async sibling prefixed with `a`:
anew / afetch / alist / asave / aupdate / adelete / arun.
"""

import asyncio

from vectorshift.transformation import IOConfig, IOType, Transformation


async def main() -> None:
    t = await Transformation.anew(
        name="async_double",
        function_name="double",
        inputs={"n": IOConfig(io_type=IOType.INT)},
        outputs={"result": IOConfig(io_type=IOType.INT)},
        function="def double(n):\n    return {'result': n * 2}",
    )
    print(f"1. anew: id={t.id}")

    res = await t.arun(inputs={"n": 21})
    print(f"2. arun: {res['outputs']}")

    await t.aupdate(description="Doubles an integer.")
    print(f"3. aupdate: description={t.description!r}")

    await t.adelete()
    print("4. adelete done.")


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

1. anew: id=...
2. arun: {'result': 42}
3. aupdate: description='Doubles an integer.'
4. adelete done.