Skip to content

Commit 6521df6

Browse files
Fix insert_event compatibility with aw-server-rust
1 parent 9de8095 commit 6521df6

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

aw_client/client.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -161,8 +161,8 @@ def send_events(self, bucket_id: str, events: List[Event]):
161161

162162
def insert_event(self, bucket_id: str, event: Event) -> Event:
163163
endpoint = "buckets/{}/events".format(bucket_id)
164-
data = event.to_json_dict()
165-
return Event(**self._post(endpoint, data).json())
164+
data = [event.to_json_dict()]
165+
return Event(**self._post(endpoint, data).json()[0])
166166

167167
def insert_events(self, bucket_id: str, events: List[Event]) -> None:
168168
endpoint = "buckets/{}/events".format(bucket_id)
@@ -211,7 +211,9 @@ def heartbeat(
211211
from aw_transform.heartbeats import heartbeat_merge
212212

213213
endpoint = "buckets/{}/heartbeat?pulsetime={}".format(bucket_id, pulsetime)
214-
commit_interval = commit_interval if commit_interval else self.commit_interval
214+
commit_interval = (
215+
commit_interval if commit_interval != None else self.commit_interval
216+
)
215217

216218
if queued:
217219
# Pre-merge heartbeats

0 commit comments

Comments
 (0)