fix stream exclusion logic

Author: dbgold17

airbyte_cdk/test/standard_tests/docker_base.py

@@ -354,6 +354,11 @@ def test_docker_image_build_and_read(
                     set(streams_list) - set(stream.name for stream in scenario.empty_streams)
                 )
 
+            if scenario.empty_streams:
+                # Filter out streams marked as empty in the scenario.
+                empty_stream_names = [stream.name for stream in scenario.empty_streams]
+                streams_list = [s for s in streams_list if s.name not in empty_stream_names]
+
             configured_catalog: ConfiguredAirbyteCatalog = ConfiguredAirbyteCatalog(
                 streams=[
                     ConfiguredAirbyteStream(

airbyte_cdk/test/standard_tests/source_base.py

@@ -123,9 +123,10 @@ def test_basic_read(
         streams = discover_result.catalog.catalog.streams  # type: ignore [reportOptionalMemberAccess, union-attr]
 
         if scenario.empty_streams:
-            # Don't read from any streams marked as empty in the scenario.
-            streams = list(set(streams) - set(stream.name for stream in scenario.empty_streams))
-
+            # Filter out streams marked as empty in the scenario.
+            empty_stream_names = [stream.name for stream in scenario.empty_streams]
+            streams = [s for s in streams if s.name not in empty_stream_names]
+    
         configured_catalog = ConfiguredAirbyteCatalog(
             streams=[
                 ConfiguredAirbyteStream(