pyflink.datastream.functions.AsyncRetryPredicate.exception_predicate

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

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.