Improve Airflow parser functionality

conftest.py

@@ -22,6 +22,8 @@
 
 pytest_plugins = ["jupyter_server.pytest_plugin"]
 
+TEST_CATALOG_NAME = 'new_test_catalog'
+
 KFP_COMPONENT_CACHE_INSTANCE = {
     "display_name": "KFP Example Components",
     "metadata": {
@@ -40,6 +42,7 @@
     "schema_name": "elyra-airflow-examples-catalog"
 }
 
+
 @pytest.fixture
 def component_cache_instance(request):
     """Creates an instance of a component cache and removes after test."""
@@ -68,3 +71,22 @@ def component_cache_instance(request):
     # Test was not parametrized, so component instance is not needed
     except AttributeError:
         yield None
+
+
+@pytest.fixture
+def teardown_test_catalog():
+    """
+    This fixture is run after certain tests that modify the component catalog.
+    This way, the catalog instance will be removed even when the test fails
+    """
+    metadata_manager = MetadataManager(schemaspace=ComponentCatalogs.COMPONENT_CATALOGS_SCHEMASPACE_ID)
+
+    # Run test
+    yield
+
+    # Remove test catalog
+    try:
+        if metadata_manager.get(TEST_CATALOG_NAME):
+            metadata_manager.remove(TEST_CATALOG_NAME)
+    except Exception:
+        pass