pyflink.datastream.functions.AsyncRetryStrategy.fixed_delay
-
static AsyncRetryStrategy.fixed_delay(max_attempts: int, backoff_time_millis: int, result_predicate: Callable[[List[OUT]], bool] | None, exception_predicate: Callable[[Exception], bool] | None)[source]