pyflink.datastream.functions.AsyncRetryPredicate.exception_predicate

abstract AsyncRetryPredicate.exception_predicate() → Callable[[Exception], bool] | None

An optional Python predicate function that defines a condition on asyncFunction’s exception which will trigger a later reattempt operation, will be called before user’s ResultFuture#complete_exceptionally.