[low code connectors] read configs from package_data

airbyte-cdk/python/CHANGELOG.md

@@ -1,5 +1,8 @@
 # Changelog
 
+## 0.1.78
+- Fix yaml config parsing when running from docker container
+
 ## 0.1.77
 - Add schema validation for declarative YAML connector configs
 

airbyte-cdk/python/airbyte_cdk/sources/declarative/checks/check_stream.py

@@ -39,7 +39,7 @@ def check_connection(self, source: Source, logger: logging.Logger, config: Mappi
                     records = stream.read_records(sync_mode=SyncMode.full_refresh)
                     next(records)
                 except Exception as error:
-                    return False, f"Unable to connect to stream {stream} - {error}"
+                    return False, f"Unable to connect to stream {stream_name} - {error}"
             else:
                 raise ValueError(f"{stream_name} is not part of the catalog. Expected one of {stream_name_to_stream.keys()}")
         return True, None

airbyte-cdk/python/airbyte_cdk/sources/declarative/yaml_declarative_source.py

@@ -5,6 +5,7 @@
 import inspect
 import json
 import logging
+import pkgutil
 import typing
 from dataclasses import dataclass, fields
 from enum import Enum, EnumMeta
@@ -65,9 +66,11 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]:
         return [self._factory.create_component(stream_config, config, True)() for stream_config in self._stream_configs()]
 
     def _read_and_parse_yaml_file(self, path_to_yaml_file):
-        with open(path_to_yaml_file, "r") as f:
-            config_content = f.read()
-            return YamlParser().parse(config_content)
+        package = self.__class__.__module__.split(".")[0]
+
+        yaml_config = pkgutil.get_data(package, path_to_yaml_file)
+        decoded_yaml = yaml_config.decode()
+        return YamlParser().parse(decoded_yaml)
 
     def _validate_source(self):
         full_config = {}

airbyte-cdk/python/setup.py

@@ -15,7 +15,7 @@
 
 setup(
     name="airbyte-cdk",
-    version="0.1.77",
+    version="0.1.78",
     description="A framework for writing Airbyte Connectors.",
     long_description=README,
     long_description_content_type="text/markdown",