fix integration tests

Author: eugene-kulak

airbyte-integrations/connectors/source-facebook-marketing/integration_tests/configured_catalog.json

@@ -1,5 +1,65 @@
 {
   "streams": [
+    {
+      "stream": {
+        "name": "campaigns",
+        "json_schema": {},
+        "supported_sync_modes": ["full_refresh", "incremental"],
+        "source_defined_cursor": true,
+        "default_cursor_field": ["updated_time"],
+        "source_defined_primary_key": [["id"]],
+        "namespace": null
+      },
+      "sync_mode": "incremental",
+      "cursor_field": null,
+      "destination_sync_mode": "append",
+      "primary_key": null
+    },
+    {
+      "stream": {
+        "name": "ad_sets",
+        "json_schema": {},
+        "supported_sync_modes": ["full_refresh", "incremental"],
+        "source_defined_cursor": true,
+        "default_cursor_field": ["updated_time"],
+        "source_defined_primary_key": [["id"]],
+        "namespace": null
+      },
+      "sync_mode": "incremental",
+      "cursor_field": null,
+      "destination_sync_mode": "append",
+      "primary_key": null
+    },
+    {
+      "stream": {
+        "name": "ads",
+        "json_schema": {},
+        "supported_sync_modes": ["full_refresh", "incremental"],
+        "source_defined_cursor": true,
+        "default_cursor_field": ["updated_time"],
+        "source_defined_primary_key": [["id"]],
+        "namespace": null
+      },
+      "sync_mode": "incremental",
+      "cursor_field": null,
+      "destination_sync_mode": "append",
+      "primary_key": null
+    },
+    {
+      "stream": {
+        "name": "ad_creatives",
+        "json_schema": {},
+        "supported_sync_modes": ["full_refresh"],
+        "source_defined_cursor": null,
+        "default_cursor_field": null,
+        "source_defined_primary_key": [["id"]],
+        "namespace": null
+      },
+      "sync_mode": "full_refresh",
+      "cursor_field": null,
+      "destination_sync_mode": "append",
+      "primary_key": null
+    },
     {
       "stream": {
         "name": "ads_insights",

airbyte-integrations/connectors/source-facebook-marketing/integration_tests/test_streams.py

@@ -52,7 +52,7 @@ def test_streams_with_include_deleted(self, stream_name, deleted_id, config_with
         assert deleted_records, f"{stream_name} stream should have deleted records returned"
         assert is_specific_deleted_pulled, f"{stream_name} stream should have a deleted record with id={deleted_id}"
 
-    @pytest.mark.parametrize("stream_name, deleted_num", [("ads", 2), ("campaigns", 1), ("ad_sets", 1)])
+    @pytest.mark.parametrize("stream_name, deleted_num", [("ads", 2), ("campaigns", 3), ("ad_sets", 1)])
     def test_streams_with_include_deleted_and_state(self, stream_name, deleted_num, config_with_include_deleted, configured_catalog, state):
         """Should ignore state because of include_deleted enabled"""
         catalog = self.slice_catalog(configured_catalog, {stream_name})

airbyte-integrations/connectors/source-facebook-marketing/unit_tests/test_async_job.py

@@ -6,7 +6,7 @@
 
 import pytest
 from source_facebook_marketing.api import API
-from source_facebook_marketing.streams.async_job import AsyncJob, Status
+from source_facebook_marketing.streams.async_job import InsightAsyncJob, Status
 from source_facebook_marketing.streams.common import JobException
 
 
@@ -23,7 +23,7 @@ def adreport_fixture(mocker):
 
 @pytest.fixture(name="job")
 def job_fixture(api, mocker):
-    return AsyncJob(api=api, params=mocker.MagicMock())
+    return InsightAsyncJob(api=api, params=mocker.MagicMock())
 
 
 @pytest.fixture(name="failed_job")
@@ -49,7 +49,7 @@ def api_fixture(mocker, adreport):
     return api
 
 
-class TestAsyncJob:
+class TestInsightAsyncJob:
     def test_start(self, job):
         job.start()
 
@@ -139,7 +139,7 @@ def test_failed_yes(self, failed_job):
         assert failed_job.failed, "should return True if the job previously failed"
 
     def test_str(self, api, adreport):
-        job = AsyncJob(api=api, params={"time_range": 123, "breakdowns": [10, 20]})
+        job = InsightAsyncJob(api=api, params={"time_range": 123, "breakdowns": [10, 20]})
 
         assert str(job) == "AdReportRun(id=<None>, time_range=123, breakdowns=[10, 20]"