> Task :airbyte-integrations:connectors:source-slack:sourceAcceptanceTest ============================= test session starts ============================== platform linux -- Python 3.7.11, pytest-6.2.5, py-1.11.0, pluggy-1.0.0 rootdir: /test_input plugins: timeout-1.4.2, sugar-0.9.4 collected 18 items test_core.py ............... [ 83%] test_full_refresh.py F [ 88%] test_incremental.py Fs [100%] =================================== FAILURES =================================== ________________ TestFullRefresh.test_sequential_reads[inputs0] ________________ self = <source_acceptance_test.tests.test_full_refresh.TestFullRefresh object at 0x7eff9e7afa90> inputs = FullRefreshConfig(config_path='secrets/config.json', configured_catalog_path='integration_tests/full_refresh_catalog.json', timeout_seconds=7200, ignored_fields=None) connector_config = SecretDict(******) configured_catalog = ConfiguredAirbyteCatalog(streams=[ConfiguredAirbyteStream(stream=AirbyteStream(name='channels', json_schema=***'type': '...l_refresh'>, cursor_field=None, destination_sync_mode=<DestinationSyncMode.overwrite: 'overwrite'>, primary_key=None)]) docker_runner = <source_acceptance_test.utils.connector_runner.ConnectorRunner object at 0x7eff9e6f5bd0> detailed_logger = <AirbyteNativeLogger detailed_logger /test_input/acceptance_tests_logs/test_full_refresh.py__TestFullRefresh__test_sequential_reads[inputs0].txt (DEBUG)> def test_sequential_reads( self, inputs: ConnectionTestConfig, connector_config: SecretDict, configured_catalog: ConfiguredAirbyteCatalog, docker_runner: ConnectorRunner, detailed_logger: Logger, ): ignored_fields = getattr(inputs, "ignored_fields") or *** configured_catalog = full_refresh_only_catalog(configured_catalog) output = docker_runner.call_read(connector_config, configured_catalog) records_1 = [message.record for message in output if message.type == Type.RECORD] records_by_stream_1 = defaultdict(list) for record in records_1: records_by_stream_1[record.stream].append(record.data) output = docker_runner.call_read(connector_config, configured_catalog) records_2 = [message.record for message in output if message.type == Type.RECORD] records_by_stream_2 = defaultdict(list) for record in records_2: records_by_stream_2[record.stream].append(record.data)