fix: update Record assertions with correct stream name in test_record…

…_selector Co-Authored-By: [email protected] <[email protected]>
airbytehq · Feb 7, 2025 · a9e1f3e · a9e1f3e
1 parent dde539e
commit a9e1f3e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/unit_tests/sources/declarative/extractors/test_record_selector.py b/unit_tests/sources/declarative/extractors/test_record_selector.py
@@ -119,7 +119,7 @@ def test_record_filter(test_name, field_path, filter_template, body, expected_da
         )
     )
     assert actual_records == [
-        Record(data=data, associated_slice=stream_slice, stream_name="") for data in expected_data
+        Record(data=data, associated_slice=stream_slice, stream_name="test_stream") for data in expected_data
     ]
 
     calls = []
@@ -210,7 +210,7 @@ def test_schema_normalization(test_name, schema, schema_transformation, body, ex
         )
     )
 
-    assert actual_records == [Record(data, stream_slice) for data in expected_data]
+    assert actual_records == [Record(data=data, associated_slice=stream_slice, stream_name="test_stream") for data in expected_data]
 
 
 def create_response(body):