pyflink.datastream.functions.AsyncFunction.timeout

AsyncFunction.timeout(value: pyflink.datastream.functions.IN) → List[pyflink.datastream.functions.OUT]

In case async_invoke() timeout occurred. By default, it raises a timeout exception.