Update airbyte_cdk/sources/utils/transform.py

ChristoGrab · bnchrch · web-flow · commit c97cf85f793a · 2025-01-15T17:20:55.000-05:00
Co-authored-by: Ben Church &lt;ben@airbyte.io&gt;
diff --git a/airbyte_cdk/sources/utils/transform.py b/airbyte_cdk/sources/utils/transform.py
@@ -253,14 +253,10 @@ def _get_type_structure(self, input_data: Any, current_depth: int = 0) -> Any:
             )
 
         if isinstance(input_data, dict):
-            structure = {
+            return {
                 key: self._get_type_structure(field_value, current_depth + 1)
                 for key, field_value in input_data.items()
             }
 
-            if current_depth == 0:
-                return f"object with structure {structure}"
-            return structure
-
         else:
             return python_to_json[type(input_data)]

Original file line number	Diff line number	Diff line change
`@@ -253,14 +253,10 @@ def _get_type_structure(self, input_data: Any, current_depth: int = 0) -> Any:`
`253`	`253`	`)`
`254`	`254`
`255`	`255`	`if isinstance(input_data, dict):`
`256`		`- structure = {`
	`256`	`+ return {`
`257`	`257`	`key: self._get_type_structure(field_value, current_depth + 1)`
`258`	`258`	`for key, field_value in input_data.items()`
`259`	`259`	`}`
`260`	`260`
`261`		`- if current_depth == 0:`
`262`		`- return f"object with structure {structure}"`
`263`		`- return structure`
`264`		`-`
`265`	`261`	`else:`
`266`	`262`	`return python_to_json[type(input_data)]`