aiohttp-retry

Fix infinite retries due to callback; add callback to ListRetry

Fix 2.8.0 (#81)

* fix redurant arguments due to 2.8.0

* fix 2.8.0 #2

* fix linters

https://github.com/inyutin/aiohttp_retry/issues/79

https://github.com/inyutin/aiohttp_retry/issues/48 https://github.com/inyutin/aiohttp_retry/issues/38

Add a callback to evaluate response

Add response as param to get_timeout https://github.com/inyutin/aiohttp_retry/issues/59

Improve logging https://github.com/inyutin/aiohttp_retry/issues/58

Make it possible to set up client session explicitly https://github.com/inyutin/aiohttp_retry/issues/60

Add ClientType type to library ClientType = Union[ClientSession, RetryClient]

Set python >= 3.7 as requirement in setup.py

Fix retries timeouts: https://github.com/inyutin/aiohttp_retry/pull/68

Fix this issue: https://github.com/inyutin/aiohttp_retry/issues/42

Fix debug log, make it more accurate https://github.com/inyutin/aiohttp_retry/issues/54

• https://github.com/inyutin/aiohttp_retry/issues/41
• https://github.com/inyutin/aiohttp_retry/issues/44

Related issues: https://github.com/inyutin/aiohttp_retry/issues/29

Discussion was here: https://github.com/inyutin/aiohttp_retry/pull/13

Related issues:

• https://github.com/inyutin/aiohttp_retry/issues/23

Related issues:

• https://github.com/inyutin/aiohttp_retry/issues/22
• https://github.com/inyutin/aiohttp_retry/issues/24

You can define your own timeouts logic or use:

• ExponentialRetry with exponential backoff
• RandomRetry for random backoff
• ListRetry with backoff you predefine by list

RetryClient add current attempt number to request_trace_ctx (for more info see aiohttp doc).

import logging
import sys
from types import SimpleNamespace

from aiohttp import ClientSession, TraceConfig, TraceRequestStartParams

from aiohttp_retry import RetryClient, RetryOptions


handler = logging.StreamHandler(sys.stdout)
logging.basicConfig(handlers=[handler])
logger = logging.getLogger(__name__)
retry_options = RetryOptions(attempts=2)


async def on_request_start(
    session: ClientSession,
    trace_config_ctx: SimpleNamespace,
    params: TraceRequestStartParams,
) -> None:
    current_attempt = trace_config_ctx.trace_request_ctx['current_attempt']
    if retry_options.attempts <= current_attempt:
        logger.warning('Wow! We are in last attempt')


async def main():
    trace_config = TraceConfig()
    trace_config.on_request_start.append(on_request_start)
    retry_client = RetryClient(retry_options=retry_options, trace_configs=[trace_config])

    response = await retry_client.get('https://httpstat.us/503', ssl=False)
    print(response.status)

    await retry_client.close()

Make request awaitable:

from aiohttp_retry import RetryClient, RetryOptions

async def main():
    retry_options = RetryOptions(attempts=1)
    retry_client = RetryClient(raise_for_status=False, retry_options=retry_options)

    response = await retry_client.get('/ping')
    print(response.status)
        
    await retry_client.close()

Rewrite working with retry options. Make it possible to specify retry options for RetryClient.

Import Protocol from typing_extensions for python < 3.8 due to https://github.com/inyutin/aiohttp_retry/issues/7

Added log attempts to debug log due to https://github.com/inyutin/aiohttp_retry/issues/3.