From 5021d0cd579c0a2464b107f90f5d523509a93659 Mon Sep 17 00:00:00 2001
From: Anatolii Yatsuk <tolikyatsuk@gmail.com>
Date: Tue, 28 May 2024 13:23:48 +0300
Subject: [PATCH] Fix mypy errors

---
 .../sources/declarative/incremental/per_partition_cursor.py | 2 +-
 .../stream_slicers/cartesian_product_stream_slicer.py       | 6 ++++--
 .../connectors/source-jira/source_jira/manifest.yaml        | 4 ++--
 .../source_zendesk_support/manifest.yaml                    | 2 +-
 4 files changed, 8 insertions(+), 6 deletions(-)

diff --git a/airbyte-cdk/python/airbyte_cdk/sources/declarative/incremental/per_partition_cursor.py b/airbyte-cdk/python/airbyte_cdk/sources/declarative/incremental/per_partition_cursor.py
index e9d0fcfeea3e1..8ac77f4fd55e3 100644
--- a/airbyte-cdk/python/airbyte_cdk/sources/declarative/incremental/per_partition_cursor.py
+++ b/airbyte-cdk/python/airbyte_cdk/sources/declarative/incremental/per_partition_cursor.py
@@ -145,7 +145,7 @@ def get_stream_state(self) -> StreamState:
                         "cursor": cursor_state,
                     }
                 )
-        state = {"states": states}
+        state: dict[str, Any] = {"states": states}
 
         parent_state = self._partition_router.get_parent_state()
         if parent_state:
diff --git a/airbyte-cdk/python/airbyte_cdk/sources/declarative/stream_slicers/cartesian_product_stream_slicer.py b/airbyte-cdk/python/airbyte_cdk/sources/declarative/stream_slicers/cartesian_product_stream_slicer.py
index a5bcfea967d7b..61aa23d13b71d 100644
--- a/airbyte-cdk/python/airbyte_cdk/sources/declarative/stream_slicers/cartesian_product_stream_slicer.py
+++ b/airbyte-cdk/python/airbyte_cdk/sources/declarative/stream_slicers/cartesian_product_stream_slicer.py
@@ -158,7 +158,9 @@ def get_parent_state(self) -> Optional[Mapping[str, StreamState]]:
                                                      }
                                                  }
         """
-        combined_state = {}
+        combined_state: dict[str, StreamState] = {}
         for s in self.stream_slicers:
-            combined_state.update(s.get_parent_state())
+            parent_state = s.get_parent_state()
+            if parent_state:
+                combined_state.update(parent_state)
         return combined_state
diff --git a/airbyte-integrations/connectors/source-jira/source_jira/manifest.yaml b/airbyte-integrations/connectors/source-jira/source_jira/manifest.yaml
index 906f2cc17b810..11086b60d46f8 100644
--- a/airbyte-integrations/connectors/source-jira/source_jira/manifest.yaml
+++ b/airbyte-integrations/connectors/source-jira/source_jira/manifest.yaml
@@ -1230,7 +1230,7 @@ definitions:
     transformations:
       - type: AddFields
         fields:
-          - path: [ "issueId" ]
+          - path: ["issueId"]
             value_type: string
             value: "{{ stream_slice.issue_id }}"
     $parameters:
@@ -1255,7 +1255,7 @@ definitions:
     transformations:
       - type: AddFields
         fields:
-          - path: [ "issueId" ]
+          - path: ["issueId"]
             value_type: string
             value: "{{ stream_slice.issue_id }}"
     $parameters:
diff --git a/airbyte-integrations/connectors/source-zendesk-support/source_zendesk_support/manifest.yaml b/airbyte-integrations/connectors/source-zendesk-support/source_zendesk_support/manifest.yaml
index 19e0283bdba29..b07993c0939c8 100644
--- a/airbyte-integrations/connectors/source-zendesk-support/source_zendesk_support/manifest.yaml
+++ b/airbyte-integrations/connectors/source-zendesk-support/source_zendesk_support/manifest.yaml
@@ -576,7 +576,7 @@ definitions:
         type: RecordSelector
         extractor:
           type: DpathExtractor
-          field_path: [ "articles" ]
+          field_path: ["articles"]
     $parameters:
       name: "articles"
       path: "help_center/incremental/articles"