File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 66import uuid
77from concurrent .futures import ThreadPoolExecutor
88
9+ import dateutil .parser
10+
911from .base import BaseBufferManager
1012
1113logger = logging .getLogger (__name__ )
@@ -30,9 +32,7 @@ def object_hook(self, o):
3032 type_ = o .get ("_type" )
3133 if type_ != "datetime.datetime" :
3234 return o
33-
34- t = o ['_type' ]
35- return datetime .datetime .fromisoformat (o ["value" ])
35+ return dateutil .parser .parse (o ["value" ])
3636
3737
3838class DurableBuffer :
Original file line number Diff line number Diff line change 33import socket
44import time
55import uuid
6- from datetime import datetime
6+ import dateutil . parser
77
88import click
99from aiohttp import web
@@ -89,7 +89,7 @@ async def read_responses():
8989 for _ in ping_iter ():
9090 payload = await self .controller .recv ()
9191 dta = json .loads (payload )
92- duration = datetime . fromisoformat (dta ["response_time" ]) - datetime . fromisoformat (
92+ duration = dateutil . parser . parse (dta ["response_time" ]) - dateutil . parser . parse (
9393 dta ["initial_time" ]
9494 )
9595 responses .append (duration .total_seconds ())
You can’t perform that action at this time.
0 commit comments