Commit 5d06b08 1 parent c80cc36 commit 5d06b08 Copy full SHA for 5d06b08
File tree 1 file changed +3
-5
lines changed
1 file changed +3
-5
lines changed Original file line number Diff line number Diff line change 21
21
import requests as req
22
22
from aw_core .dirs import get_data_dir
23
23
from aw_core .models import Event
24
+ from aw_transform .heartbeats import heartbeat_merge
24
25
25
26
from .config import load_config
26
27
from .singleinstance import SingleInstance
31
32
32
33
33
34
def _log_request_exception (e : req .RequestException ):
34
- r = e .response
35
35
logger .warning (str (e ))
36
36
try :
37
- d = r . json ()
37
+ d = e . response . json () if e . response else None
38
38
logger .warning (f"Error message received: { d } " )
39
39
except json .JSONDecodeError :
40
40
pass
@@ -152,7 +152,7 @@ def get_event(
152
152
event = self ._get (endpoint ).json ()
153
153
return Event (** event )
154
154
except req .exceptions .HTTPError as e :
155
- if e .response .status_code == 404 :
155
+ if e .response and e . response .status_code == 404 :
156
156
return None
157
157
else :
158
158
raise
@@ -230,8 +230,6 @@ def heartbeat(
230
230
the function will in that case always returns None.
231
231
"""
232
232
233
- from aw_transform .heartbeats import heartbeat_merge
234
-
235
233
endpoint = f"buckets/{ bucket_id } /heartbeat?pulsetime={ pulsetime } "
236
234
_commit_interval = commit_interval or self .commit_interval
237
235
You can’t perform that action at this time.
0 commit comments