__init__.py 文件源码

def fetch_users_awake():
    @retry(
        stop_max_delay=30000,  # 30 seconds max
        wait_exponential_multiplier=100,  # wait 2^i * 100 ms, on the i-th retry
        wait_exponential_max=1000,  # but wait 1 second per try maximum
        wrap_exception=True
    )
    def retry_fetch_fail_after_30sec():
        return requests.get(config['webservice']['i_am_awake_url']).json()

    try:
        return retry_fetch_fail_after_30sec()
    except RetryError:
        return {}