Fix mypy errors

airbytehq · May 28, 2024 · 5021d0c · 5021d0c
1 parent 86d26b5
commit 5021d0c
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 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
@@ -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/.../python/airbyte_cdk/sources/declarative/stream_slicers/cartesian_product_stream_slicer.py b/.../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
@@ -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
@@ -576,7 +576,7 @@ definitions:
         type: RecordSelector
         extractor:
           type: DpathExtractor
-          field_path: [ "articles" ]
+          field_path: ["articles"]
     $parameters:
       name: "articles"
       path: "help_center/incremental/articles"