pyflink.datastream.functions.AsyncRetryPredicate.result_predicate

abstract AsyncRetryPredicate.result_predicate() → Optional[Callable[[List[pyflink.datastream.functions.OUT]], bool]]

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