Update test asserts

Author: k-fish

tests/integration/test_ourlogs.py

@@ -85,7 +85,6 @@ def test_ourlog_extraction_with_otel_logs(
     relay.send_envelope(project_id, envelope)
 
     ourlogs = ourlogs_consumer.get_ourlogs()
-    assert len(ourlogs) == 1
     expected = {
         "organization_id": 1,
         "project_id": 42,
@@ -98,6 +97,7 @@ def test_ourlog_extraction_with_otel_logs(
         "span_id": "eee19b7ec3c1b174",
         "severity_text": "Information",
         "severity_number": 10,
+        "received": time_within_delta(start, expect_resolution="s"),
         "attributes": {
             "string.attribute": {"string_value": "some string"},
             "boolean.attribute": {"bool_value": True},
@@ -112,10 +112,9 @@ def test_ourlog_extraction_with_otel_logs(
         },
     }
 
-    del ourlogs[0]["received"]
     del ourlogs[0]["attributes"]["sentry.observed_timestamp_nanos"]
 
-    assert ourlogs[0] == expected
+    assert ourlogs == [expected]
 
     ourlogs_consumer.assert_empty()
 
@@ -154,13 +153,13 @@ def test_ourlog_extraction_with_sentry_logs(
     relay.send_envelope(project_id, envelope)
 
     ourlogs = ourlogs_consumer.get_ourlogs()
-    assert len(ourlogs) == 1
     expected = {
         "organization_id": 1,
         "project_id": 42,
         "retention_days": 90,
         "timestamp_nanos": time_within_delta(start, expect_resolution="ns"),
         "observed_timestamp_nanos": time_within_delta(start, expect_resolution="ns"),
+        "received": time_within_delta(start, expect_resolution="s"),
         "trace_id": "5b8efff798038103d269b633813fc60c",
         "body": "Example log record",
         "span_id": "eee19b7ec3c1b174",
@@ -174,9 +173,7 @@ def test_ourlog_extraction_with_sentry_logs(
         },
     }
 
-    del ourlogs[0]["received"]
-    assert ourlogs[0] == expected
-
+    assert ourlogs == [expected]
     ourlogs_consumer.assert_empty()
 
 
@@ -208,13 +205,13 @@ def test_ourlog_extraction_with_sentry_logs_with_missing_fields(
     relay.send_envelope(project_id, envelope)
 
     ourlogs = ourlogs_consumer.get_ourlogs()
-    assert len(ourlogs) == 1
     expected = {
         "organization_id": 1,
         "project_id": 42,
         "retention_days": 90,
         "timestamp_nanos": time_within_delta(start, expect_resolution="ns"),
         "observed_timestamp_nanos": time_within_delta(start, expect_resolution="ns"),
+        "received": time_within_delta(start, expect_resolution="s"),
         "trace_id": "5b8efff798038103d269b633813fc60c",
         "body": "Example log record 2",
         "severity_text": "warn",
@@ -224,8 +221,8 @@ def test_ourlog_extraction_with_sentry_logs_with_missing_fields(
             "sentry.severity_text": {"string_value": "warn"},
         },
     }
-    del ourlogs[0]["received"]
-    assert ourlogs[0] == expected
+    assert ourlogs == [expected]
+    ourlogs_consumer.assert_empty()
 
 
 def test_ourlog_extraction_is_disabled_without_feature(
@@ -245,6 +242,6 @@ def test_ourlog_extraction_is_disabled_without_feature(
     relay.send_envelope(project_id, envelope)
 
     ourlogs = ourlogs_consumer.get_ourlogs()
-    assert len(ourlogs) == 0
 
+    assert len(ourlogs) == 0
     ourlogs_consumer.assert_empty()