AirbyteLib: Add 'get_available_connectors()' option (#34982)

airbyte-lib/airbyte_lib/__init__.py

@@ -5,6 +5,7 @@
 from airbyte_lib._factories.connector_factories import get_source
 from airbyte_lib.caches import DuckDBCache, DuckDBCacheConfig
 from airbyte_lib.datasets import CachedDataset
+from airbyte_lib.registry import get_available_connectors
 from airbyte_lib.results import ReadResult
 from airbyte_lib.secrets import SecretSource, get_secret
 from airbyte_lib.source import Source
@@ -14,6 +15,7 @@
     "CachedDataset",
     "DuckDBCache",
     "DuckDBCacheConfig",
+    "get_available_connectors",
     "get_source",
     "get_default_cache",
     "get_secret",

airbyte-lib/airbyte_lib/registry.py

@@ -105,3 +105,13 @@ def get_connector_metadata(name: str) -> ConnectorMetadata:
             },
         )
     return cache[name]
+
+
+def get_available_connectors() -> list[str]:
+    """Return a list of all available connectors.
+
+    Connectors will be returned in alphabetical order, with the standard prefix "source-".
+    """
+    return sorted(
+        conn.name for conn in _get_registry_cache().values() if conn.pypi_package_name is not None
+    )

airbyte-lib/tests/integration_tests/test_source_test_fixture.py

@@ -62,6 +62,10 @@ def test_registry_get():
     assert metadata.latest_available_version == "0.0.1"
 
 
+def test_registry_list() -> None:
+    assert registry.get_available_connectors() == ["source-test"]
+
+
 def test_list_streams(expected_test_stream_data: dict[str, list[dict[str, str | int]]]):
     source = ab.get_source(
         "source-test", config={"apiKey": "test"}, install_if_missing=False