Fix tests

Author: bnchrch

airbyte-ci/connectors/pipelines/poetry.lock

@@ -20,7 +20,7 @@ airbyte-protocol-models = "*"
 tabulate = "^0.8.9"
 jinja2 = "^3.0.2"
 requests = "^2.28.2"
-connector-ops = {path = "../connector_ops"}
+connector-ops = {path = "../connector_ops", develop = true}
 toml = "^0.10.2"
 sentry-sdk = "^1.28.1"
 

airbyte-ci/connectors/pipelines/pyproject.toml

@@ -25,6 +25,7 @@ def test_get_selected_connectors_by_name_no_file_modification():
         selected_languages=(),
         modified=False,
         metadata_changes_only=False,
+        metadata_query=None,
         modified_files=set(),
     )
 
@@ -41,6 +42,7 @@ def test_get_selected_connectors_by_support_level_no_file_modification():
         selected_languages=(),
         modified=False,
         metadata_changes_only=False,
+        metadata_query=None,
         modified_files=set(),
     )
 
@@ -54,6 +56,7 @@ def test_get_selected_connectors_by_language_no_file_modification():
         selected_languages=(ConnectorLanguage.LOW_CODE,),
         modified=False,
         metadata_changes_only=False,
+        metadata_query=None,
         modified_files=set(),
     )
 
@@ -69,6 +72,7 @@ def test_get_selected_connectors_by_name_with_file_modification():
         selected_languages=(),
         modified=False,
         metadata_changes_only=False,
+        metadata_query=None,
         modified_files=modified_files,
     )
 
@@ -87,6 +91,7 @@ def test_get_selected_connectors_by_name_and_support_level_or_languages_leads_to
         selected_languages=(connector.language,),
         modified=False,
         metadata_changes_only=False,
+        metadata_query=None,
         modified_files=modified_files,
     )
 
@@ -103,6 +108,7 @@ def test_get_selected_connectors_with_modified():
         selected_languages=(),
         modified=True,
         metadata_changes_only=False,
+        metadata_query=None,
         modified_files=modified_files,
     )
 
@@ -119,6 +125,7 @@ def test_get_selected_connectors_with_modified_and_language():
         selected_languages=(ConnectorLanguage.JAVA,),
         modified=True,
         metadata_changes_only=False,
+        metadata_query=None,
         modified_files=modified_files,
     )
 
@@ -136,6 +143,7 @@ def test_get_selected_connectors_with_modified_and_support_level():
         selected_languages=(),
         modified=True,
         metadata_changes_only=False,
+        metadata_query=None,
         modified_files=modified_files,
     )
 
@@ -157,6 +165,7 @@ def test_get_selected_connectors_with_modified_and_metadata_only():
         selected_languages=(),
         modified=True,
         metadata_changes_only=True,
+        metadata_query=None,
         modified_files=modified_files,
     )
 
@@ -182,6 +191,7 @@ def test_get_selected_connectors_with_metadata_only():
         selected_languages=(),
         modified=False,
         metadata_changes_only=True,
+        metadata_query=None,
         modified_files=modified_files,
     )
 
@@ -192,6 +202,23 @@ def test_get_selected_connectors_with_metadata_only():
         second_modified_connector.code_directory / "setup.py",
     }
 
+def test_get_selected_connectors_with_metadata_query():
+    connector = pick_a_random_connector()
+    metadata_query = f"data.dockerRepository == '{connector.metadata['dockerRepository']}'"
+    selected_connectors = connectors.get_selected_connectors_with_modified_files(
+        selected_names=(),
+        selected_support_levels=(),
+        selected_languages=(),
+        modified=False,
+        metadata_changes_only=False,
+        metadata_query=metadata_query,
+        modified_files=set(),
+    )
+
+    assert len(selected_connectors) == 1
+    assert isinstance(selected_connectors[0], ConnectorWithModifiedFiles)
+    assert selected_connectors[0].technical_name == connector.technical_name
+    assert not selected_connectors[0].modified_files
 
 @pytest.fixture()
 def click_context_obj():