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.