Updates config_change_callback to only pass config

airbyte/_connector_base.py

@@ -56,7 +56,7 @@ def __init__(
         executor: Executor,
         name: str,
         config: dict[str, Any] | None = None,
-        config_change_callback: Callable[[dict[str, Any], int], None] | None = None,
+        config_change_callback: Callable[[dict[str, Any]], None] | None = None,
         *,
         validate: bool = False,
     ) -> None:
@@ -388,7 +388,7 @@ def _peek_airbyte_message(
             and message.control.type == "CONNECTOR_CONFIG"
             and self.config_change_callback is not None
         ):
-            self.config_change_callback(message.control.config, message.control.emitted_at)
+            self.config_change_callback(message.control.config)
             return
 
     def _execute(

airbyte/destinations/base.py

@@ -50,7 +50,7 @@ def __init__(
         executor: Executor,
         name: str,
         config: dict[str, Any] | None = None,
-        config_change_callback: Callable[[dict[str, Any], int], None] | None = None,
+        config_change_callback: Callable[[dict[str, Any]], None] | None = None,
         *,
         validate: bool = False,
     ) -> None:

airbyte/destinations/util.py

@@ -20,7 +20,7 @@
 def get_destination(
     name: str,
     config: dict[str, Any] | None = None,
-    config_change_callback: Callable[[dict[str, Any], int], None] | None = None,
+    config_change_callback: Callable[[dict[str, Any]], None] | None = None,
     *,
     version: str | None = None,
     pip_url: str | None = None,

airbyte/sources/base.py

@@ -58,7 +58,7 @@ def __init__(
         executor: Executor,
         name: str,
         config: dict[str, Any] | None = None,
-        config_change_callback: Callable[[dict[str, Any], int], None] | None = None,
+        config_change_callback: Callable[[dict[str, Any]], None] | None = None,
         streams: str | list[str] | None = None,
         *,
         validate: bool = False,

airbyte/sources/util.py

@@ -46,7 +46,7 @@ def get_connector(
 def get_source(  # noqa: PLR0913 # Too many arguments
     name: str,
     config: dict[str, Any] | None = None,
-    config_change_callback: Callable[[dict[str, Any], int], None] | None = None,
+    config_change_callback: Callable[[dict[str, Any]], None] | None = None,
     *,
     streams: str | list[str] | None = None,
     version: str | None = None,
@@ -74,6 +74,7 @@ def get_source(  # noqa: PLR0913 # Too many arguments
         name: connector name
         config: connector config - if not provided, you need to set it later via the set_config
             method.
+        config_change_callback: callback function to be called when the connector config changes.
         streams: list of stream names to select for reading. If set to "*", all streams will be
             selected. If not provided, you can set it later via the `select_streams()` or
             `select_all_streams()` method.