commit from vm

Author: JustinASmith

estuary-cdk/estuary_cdk/capture/base_capture_connector.py

@@ -164,7 +164,7 @@ async def _encrypt_config(
         config: EndpointConfig,
     ) -> dict[str, Any]:
         assert isinstance(config, BaseModel)
-        ENCRYPTION_URL = "https://config-encryption.estuary.dev/v1/encrypt-config"
+        ENCRYPTION_URL = "http://localhost:8765/v1/encrypt-config"
 
         # mode="json" converts Python-specific concepts (like datetimes) to valid JSON.
         # include=config.model_fields_set ensures only the fields that are explicitly set on the

source-shopify-native/source_shopify_native/__init__.py

@@ -215,8 +215,9 @@ async def open(
 
         # Persist migrated config so UI shows the new format
         if config._was_migrated:
-            log.info("Persisting migrated config to multi-store format")
+            log.info("Persisting migrated config to multi-store format", extra={"config": config})
             encrypted_config = await self._encrypt_config(log, config)
+            log.info("Persisting migrated config to multi-store format", extra={"encrypted_config": encrypted_config})
             log.event.config_update(
                 "Migrating legacy single-store config to multi-store format.",
                 encrypted_config

source-shopify-native/source_shopify_native/models.py

@@ -149,11 +149,16 @@ def transform_legacy_config(cls, data: Any) -> Any:
 
         Sets _was_migrated flag so the connector can persist the new format.
         """
+        import logging
+        logger = logging.getLogger("source-shopify-native:models:EndpointConfig:transform_legacy_config")
+
         if not isinstance(data, dict):
+            logger.debug("Config data is not a dict; skipping migration.", extra={"data": data})
             return data
 
         # Already in new format or missing required legacy fields
         if "stores" in data or "store" not in data or "credentials" not in data:
+            logger.debug("Config data is already in new format or missing legacy fields; skipping migration.", extra={"data": data})
             return data
 
         # Transform legacy format to new format
@@ -162,13 +167,9 @@ def transform_legacy_config(cls, data: Any) -> Any:
         data["stores"] = [{"store": store, "credentials": credentials}]
         data["_was_migrated"] = True
 
-        return data
-
-    def __init__(self, **data: Any) -> None:
-        was_migrated = data.pop("_was_migrated", False)
-        super().__init__(**data)
-        self._was_migrated = was_migrated
+        logger.info("Migrated legacy config to new stores format.", extra={"data": data})
 
+        return data
 
 ConnectorState = GenericConnectorState[ResourceState]