lxl0928 / retrying-async Goto Github PK

`import asyncio

from retrying_async import retry

counter = 0

@Retry(attempts=3, delay=3)
async def fn():
global counter

counter += 1

if counter == 1:
    raise RuntimeError

async def main():
await fn()

loop = asyncio.get_event_loop()

loop.run_until_complete(main())

assert counter == 2

loop.close()
`
The above exception was the direct cause of the following exception:

Traceback (most recent call last):
File "/home/WorkSpace/bili_huahuo_spider/tests/test_retry.py", line 28, in
loop.run_until_complete(main())
File "/usr/lib/python3.7/asyncio/base_events.py", line 579, in run_until_complete
return future.result()
File "/home/WorkSpace/bili_huahuo_spider/tests/test_retry.py", line 23, in main
await fn()
File "/home/.virtualenvs/bili_huahuo_spider/lib/python3.7/site-packages/retrying_async.py", line 169, in wrapped
raise fallback from exc
retrying_async.RetryError
sys:1: RuntimeWarning: coroutine 'fn' was never awaited

I am using the retry decorator with an async method:

import asyncio

from retrying_async import retry


@retry(attempts='infinite', delay=3)
async def a():
    await b()
    while True:
        try:
            print("Hi")
            await asyncio.sleep(1)
        except Exception as exception:
            print(type(exception))
            print("Exception encountered")
            raise exception


async def b():
    print("hi")


if __name__ == "__main__":
    asyncio.run(a())

Getting this exception here:

Hi
Hi
Hi
Hi
Hi
Hi
Hi
Hi
Hi
Hi
Hi
Hi
Hi
<class 'concurrent.futures._base.CancelledError'>
Exception encountered

Any suggestions here ? This does not happen if I remove the retry decorator.