pyflink.datastream.functions.AsyncRetryPredicate.result_predicate# abstract AsyncRetryPredicate.result_predicate() → Callable[[List[OUT]], bool] | None[source]# 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.
