test: remove set_expected_logs from concurrent scenarios (non-deterministic ordering)

Co-Authored-By: unknown <>

Author: devin-ai-integration[bot]

unit_tests/sources/streams/concurrent/scenarios/stream_facade_scenarios.py

@@ -122,38 +122,6 @@
             ]
         }
     )
-    .set_expected_logs(
-        {
-            "read": [
-                {"level": "INFO", "message": "Starting syncing"},
-                {"level": "INFO", "message": "Partition generation STARTED for stream=stream1"},
-                {"level": "INFO", "message": "Marking stream stream1 as STARTED"},
-                {
-                    "level": "INFO",
-                    "message": "Partition generation: enqueuing partition #1 for stream=stream1, slice=None",
-                },
-                {"level": "INFO", "message": "Syncing stream: stream1"},
-                {
-                    "level": "INFO",
-                    "message": "Partition generation COMPLETED for stream=stream1: 1 partitions in",
-                },
-                {
-                    "level": "INFO",
-                    "message": "Partition read STARTED for stream=stream1, slice=None",
-                },
-                {
-                    "level": "INFO",
-                    "message": "Partition read COMPLETED for stream=stream1: 2 records in",
-                },
-                {"level": "INFO", "message": "Marking stream stream1 as RUNNING"},
-                {"level": "INFO", "message": "Read 2 records from stream1 stream"},
-                {"level": "INFO", "message": "Marking stream stream1 as STOPPED"},
-                {"level": "INFO", "message": "Finished syncing stream1"},
-                {"level": "INFO", "message": "Finished syncing"},
-            ]
-        }
-    )
-    .set_log_levels({"ERROR", "WARN", "WARNING", "INFO", "DEBUG"})
     .build()
 )
 

unit_tests/sources/streams/concurrent/scenarios/thread_based_concurrent_stream_scenarios.py

@@ -274,38 +274,6 @@
             {"data": {"id": "2"}, "stream": "stream1"},
         ]
     )
-    .set_expected_logs(
-        {
-            "read": [
-                {"level": "INFO", "message": "Starting syncing"},
-                {"level": "INFO", "message": "Partition generation STARTED for stream=stream1"},
-                {"level": "INFO", "message": "Marking stream stream1 as STARTED"},
-                {
-                    "level": "INFO",
-                    "message": "Partition generation: enqueuing partition #1 for stream=stream1, slice=None",
-                },
-                {"level": "INFO", "message": "Syncing stream: stream1"},
-                {
-                    "level": "INFO",
-                    "message": "Partition generation COMPLETED for stream=stream1: 1 partitions in",
-                },
-                {
-                    "level": "INFO",
-                    "message": "Partition read STARTED for stream=stream1, slice=None",
-                },
-                {
-                    "level": "INFO",
-                    "message": "Partition read COMPLETED for stream=stream1: 2 records in",
-                },
-                {"level": "INFO", "message": "Marking stream stream1 as RUNNING"},
-                {"level": "INFO", "message": "Read 2 records from stream1 stream"},
-                {"level": "INFO", "message": "Marking stream stream1 as STOPPED"},
-                {"level": "INFO", "message": "Finished syncing stream1"},
-                {"level": "INFO", "message": "Finished syncing"},
-            ]
-        }
-    )
-    .set_log_levels({"ERROR", "WARN", "WARNING", "INFO", "DEBUG"})
     .set_expected_catalog(
         {
             "streams": [