def _delete_resource()

in src/common/data_mesh/src/data_mesh_client.py [0:0]

• 22 lines of code
• 6 McCabe index (conditional complexity)

    def _delete_resource(self, resource_type: Type[object], display_name: str,
                         name: str) -> None:
        """Deletes the specified resource.

        Args:
            resource_type: A data_mesh_types dataclass type associated with a
                resource, e.g. PolicyTaxonomy.
            display_name: Display name of resource.
            name: String that uniquely identifies the resource.
        """
        if resource_type == dmt.CatalogTagTemplate:
            # Deletes all tags that use this template.
            self._catalog_client.delete_tag_template(name=name,
                                                     force=True,
                                                     retry=self._retry_options)
        elif resource_type == dmt.CatalogTag:
            self._catalog_client.delete_tag(name=name,
                                            retry=self._retry_options)
        elif resource_type == dmt.PolicyTaxonomy:
            self._policy_tag_client.delete_taxonomy(name=name,
                                                    retry=self._retry_options)
        elif resource_type == dmt.PolicyTag:
            self._policy_tag_client.delete_policy_tag(name=name,
                                                      retry=self._retry_options)
        elif resource_type == dmt.DataPolicy:
            self._bq_datapolicy_client.delete_data_policy(
                name=name, retry=self._retry_options)
        else:
            raise cortex_exc.NotImplementedCError(f"Type: {resource_type}")

        logging.info("Deleted existing %s: '%s'", resource_type.__name__,
                     display_name)