# # Copyright 2018-2022 Elyra Authors # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. # from typing import Any from elyra.metadata.metadata import Metadata # Rather than importing only the ComponentCache class needed in the post_save and # post_delete hooks below, the component_catalog module must be imported in its # entirety in order to avoid a circular reference issue try: from elyra.pipeline import component_catalog except ImportError: import sys component_catalog = sys.modules[__package__ + ".component_catalog"] from elyra.pipeline.runtime_type import RuntimeProcessorType # noqa:I202 class ComponentRegistryMetadata(Metadata): pass class ComponentCatalogMetadata(Metadata): """ This class contains methods to trigger cache updates on modification and deletion of component catalog metadata instances. """ @property def runtime_type(self) -> RuntimeProcessorType: return RuntimeProcessorType.get_instance_by_name(self.metadata["runtime_type"]) def post_save(self, **kwargs: Any) -> None: try: # Modify components associated with this catalog on creates and updates. component_catalog.ComponentCache.instance().update(catalog=self, action="modify") except Exception: # An attempted component cache update will fail silently with most errors # logged from the ComponentCache class methods. However, a log message # should eventually be added here as well pass def post_delete(self, **kwargs: Any) -> None: try: # Remove components associated with this catalog on deletes. component_catalog.ComponentCache.instance().update(catalog=self, action="delete") except Exception: # An attempted component cache update will fail silently with most errors # logged from the ComponentCache class methods. However, a log message # should eventually be added here as well pass class UrlCatalogMetadata(ComponentCatalogMetadata): pass class DirectoryCatalogMetadata(ComponentCatalogMetadata): pass class FilenameCatalogMetadata(ComponentCatalogMetadata): pass