pyflink.datastream.functions.AsyncRetryStrategy.get_retry_predicate# abstract AsyncRetryStrategy.get_retry_predicate() → pyflink.datastream.functions.AsyncRetryPredicate[pyflink.datastream.functions.OUT][source]# Returns the defined retry predicate.