Function decrement

python/pathway/tests/test_persistence.py:901–904

(a: int)

        @pw.udf(executor=pw.udfs.fully_async_executor())
        async def decrement(a: int) -> int:
            while not can_pass[a]:
                await asyncio.sleep(1)
            return a - 1

    else: