1.15.4.dev2+g3e3ce2426

flytekit.utils.rate_limiter

Directory

Classes

Class Description
RateLimiter Rate limiter that allows up to a certain number of requests per minute.
datetime datetime(year, month, day[, hour[, minute[, second[, microsecond[,tzinfo]]]]]).
deque deque([iterable[, maxlen]]) –> deque object.
timedelta Difference between two datetime values.

flytekit.utils.rate_limiter.RateLimiter

Rate limiter that allows up to a certain number of requests per minute.

def RateLimiter(
    rpm: int,
):
Parameter Type
rpm int

Methods

Method Description
acquire() None
sync_acquire() None

acquire()

def acquire()

sync_acquire()

def sync_acquire()

flytekit.utils.rate_limiter.datetime

datetime(year, month, day[, hour[, minute[, second[, microsecond[,tzinfo]]]]])

The year, month and day arguments are required. tzinfo may be None, or an instance of a tzinfo subclass. The remaining arguments may be ints.

flytekit.utils.rate_limiter.deque

deque([iterable[, maxlen]]) –> deque object

A list-like sequence optimized for data accesses near its endpoints.

flytekit.utils.rate_limiter.timedelta

Difference between two datetime values.

timedelta(days=0, seconds=0, microseconds=0, milliseconds=0, minutes=0, hours=0, weeks=0)

All arguments are optional and default to 0. Arguments may be integers or floats, and may be positive or negative.