diff --git a/airbyte-integrations/connectors/source-amazon-ads/integration_tests/configured_catalog_report.json b/airbyte-integrations/connectors/source-amazon-ads/integration_tests/configured_catalog_report.json index 26d697a48e1d..ded3a860befb 100644 --- a/airbyte-integrations/connectors/source-amazon-ads/integration_tests/configured_catalog_report.json +++ b/airbyte-integrations/connectors/source-amazon-ads/integration_tests/configured_catalog_report.json @@ -5,7 +5,12 @@ "name": "sponsored_products_report_stream", "json_schema": {}, "supported_sync_modes": ["full_refresh", "incremental"], - "source_defined_primary_key": [["profileId"], ["recordType"], ["reportDate"], ["updatedAt"]] + "source_defined_primary_key": [ + ["profileId"], + ["recordType"], + ["reportDate"], + ["updatedAt"] + ] }, "sync_mode": "incremental", "destination_sync_mode": "overwrite" diff --git a/airbyte-integrations/connectors/source-harvest/unit_tests/conftest.py b/airbyte-integrations/connectors/source-harvest/unit_tests/conftest.py index fd66898034ab..b0962911b040 100644 --- a/airbyte-integrations/connectors/source-harvest/unit_tests/conftest.py +++ b/airbyte-integrations/connectors/source-harvest/unit_tests/conftest.py @@ -10,7 +10,6 @@ def config_fixture(requests_mock): url = "https://id.getharvest.com/api/v2/oauth2/token" requests_mock.get(url, json={}) - config = {"account_id": "ID", "replication_start_date": "2021-01-01T21:20:07Z", "credentials": {"api_token": "TOKEN"}} return config diff --git a/airbyte-integrations/connectors/source-harvest/unit_tests/unit_test.py b/airbyte-integrations/connectors/source-harvest/unit_tests/unit_test.py index 582b3fba1785..5138f68da87f 100644 --- a/airbyte-integrations/connectors/source-harvest/unit_tests/unit_test.py +++ b/airbyte-integrations/connectors/source-harvest/unit_tests/unit_test.py @@ -77,6 +77,7 @@ def test_report_base_stream(config, from_date, mock_stream): mock_stream("reports/expenses/clients", response={"results": [{"client_id": 1}]}) invoice_payments_instance = ExpensesClients(authenticator=NoAuth(), from_date=from_date) - invoice_payments = invoice_payments_instance.read_records(sync_mode=None) + stream_slice = next(invoice_payments_instance.stream_slices(sync_mode=None)) + invoice_payments = invoice_payments_instance.read_records(sync_mode=None, stream_slice=stream_slice) assert next(invoice_payments)