Skip to content

Commit

Permalink
fix: replaced use of deprecated send_events with insert_events
Browse files Browse the repository at this point in the history
  • Loading branch information
ErikBjare committed Sep 28, 2021
1 parent 6c7c1bd commit ea245b3
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions tests/test_client.py
Expand Up @@ -166,19 +166,19 @@ def test_list_buckets(aw_client, bucket):
assert bucket in buckets.keys()


def test_send_event(aw_client, bucket):
def test_insert_event(aw_client, bucket):
event = Event(timestamp=datetime.now(tz=timezone.utc), data={"label": "test"})
aw_client.send_event(bucket, event)
aw_client.insert_event(bucket, event)
recv_events = aw_client.get_events(bucket, limit=1)
assert recv_events == [event]


def test_send_events(aw_client, bucket):
def test_insert_events(aw_client, bucket):
events = _create_periodic_events(
2, start=datetime.now(tz=timezone.utc) - timedelta(days=1)
)

aw_client.send_events(bucket, events)
aw_client.insert_events(bucket, events)
recv_events = aw_client.get_events(bucket)

# Why isn't reverse=True needed here?
Expand All @@ -191,7 +191,7 @@ def test_get_events_interval(aw_client, bucket):
delta = timedelta(hours=1)
events = _create_periodic_events(1000, delta=delta, start=start_dt)

aw_client.send_events(bucket, events)
aw_client.insert_events(bucket, events)

# start kwarg isn't currently range-inclusive
recv_events = aw_client.get_events(bucket, limit=50, start=start_dt, end=end_dt)
Expand Down Expand Up @@ -219,7 +219,7 @@ def test_store_many_events(aw_client, bucket):
1000, start=datetime.now(tz=timezone.utc) - timedelta(days=50)
)

aw_client.send_events(bucket, events)
aw_client.insert_events(bucket, events)
recv_events = aw_client.get_events(bucket, limit=-1)

assert len(events) == len(recv_events)
Expand All @@ -231,7 +231,7 @@ def test_midnight(aw_client, bucket):
midnight = start_dt.replace(hour=23, minute=50)
events = _create_periodic_events(100, start=midnight, delta=timedelta(minutes=1))

aw_client.send_events(bucket, events)
aw_client.insert_events(bucket, events)
recv_events = aw_client.get_events(bucket, limit=-1)
assert len(recv_events) == len(events)

Expand Down

0 comments on commit ea245b3

Please sign in to comment.