pyflink.datastream.async_retry_predicates.has_exception_predicate# has_exception_predicate(error)[source]#