File tree 1 file changed +5
-4
lines changed
services/web/server/src/simcore_service_webserver/resource_manager
1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change 3
3
import aioredis
4
4
from aiohttp import web
5
5
from aioredlock import Aioredlock
6
- from tenacity import Retrying , before_log , stop_after_attempt , wait_random
7
-
8
6
from servicelib .application_keys import APP_CONFIG_KEY
7
+ from tenacity import Retrying , after_log , stop_after_attempt , wait_random
9
8
10
9
from .config import (
11
10
APP_CLIENT_REDIS_CLIENT_KEY ,
21
20
retry_upon_init_policy = dict (
22
21
stop = stop_after_attempt (3 ),
23
22
wait = wait_random (min = 1 , max = 2 ),
24
- before = before_log (log , logging .WARNING ),
23
+ after = after_log (log , logging .WARNING ),
25
24
)
26
25
27
26
@@ -33,7 +32,9 @@ async def redis_client(app: web.Application):
33
32
client = None
34
33
for attempt in Retrying (** retry_upon_init_policy ):
35
34
with attempt :
36
- client : aioredis .Redis = await aioredis .create_redis_pool (url , encoding = "utf-8" )
35
+ client : aioredis .Redis = await aioredis .create_redis_pool (
36
+ url , encoding = "utf-8"
37
+ )
37
38
# create lock manager
38
39
lock_manager = Aioredlock ([url ])
39
40
You can’t perform that action at this time.
0 commit comments