diff --git a/airbyte/_processors/sql/base.py b/airbyte/_processors/sql/base.py index c949fdb2..9beb0b97 100644 --- a/airbyte/_processors/sql/base.py +++ b/airbyte/_processors/sql/base.py @@ -161,11 +161,6 @@ def register_source( This method is called by the source when it is initialized. """ self._source_name = source_name - # self.register_source( - # source_name, - # incoming_source_catalog, - # stream_names=stream_names, - # ) self._ensure_schema_exists() super().register_source( source_name,