src/common/data_mesh/src/data_mesh_client.py [594:618]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            self,
            resource_spec: Any,
            existing_resources: Optional[Dict[str,
                                              str]] = None) -> Optional[str]:
        """Make the specified resource ready for a create request.

        This involves tasks like deleting the existing resource for overwriting
        or marking the resource to skip for not overwriting.

        Returns:
            A string representing an existing resource ID that should not be
            overwritten. Otherwise returns None if the existing resource doesn't
            exist or was deleted to be overwritten.
        """
        resource_type = type(resource_spec)
        existing_id = None
        if existing_resources:
            existing_id = existing_resources.get(resource_spec.display_name)

        if not self.overwrite and existing_id:
            logging.info("Skipping existing %s: '%s'", resource_type.__name__,
                         resource_spec.display_name)
            return existing_id

        if self.overwrite and existing_id:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/common/data_mesh/src/data_mesh_client.py [625:640]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            self,
            resource_spec: Any,
            existing_resources: Optional[Dict[str,
                                              str]] = None) -> Optional[str]:
        """Same as above but supports different resource async operations."""
        resource_type = type(resource_spec)
        existing_id = None
        if existing_resources:
            existing_id = existing_resources.get(resource_spec.display_name)

        if not self.overwrite and existing_id:
            logging.info("Skipping existing %s: '%s'", resource_type.__name__,
                         resource_spec.display_name)
            return existing_id

        if self.overwrite and existing_id:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -