Hi team, does PyFlink support async I/O?
# random
t
Hi team, does PyFlink support async I/O?
j
It doesn't seem to be available as normally python examples are shown if available. To my understanding, it works with I/O bound requests (eg database query) and it would be handled by Python functions as well. If a db library supports asyncio (eg https://www.encode.io/databases/), it'd work natively or we would be able to wrap blocking db requests with asyncio on our own.
s
Yes, it doesn’t have the inbuilt feature yet.