feat(cache-provider): add on_set_prompt lifecycle hook for providers

Adds a new on_set_prompt() lifecycle hook on CacheProvider that fires after the cache key set is prepared for a new prompt. Dispatched via asyncio.create_task with errors swallowed (same fail-safe pattern as on_store / on_lookup). Why: BasicCache's lifecycle notifications to external providers were incomplete. set_prompt is a key per-prompt event that providers need visibility into — for example, to reset per-prompt timing/state used for cost-aware caching policies (a provider can set t=0 here, then measure elapsed at each on_store to estimate compute saved by a hit). Backward-compatible: default implementation is a no-op, existing providers compile and run unchanged. Providers that need the per-prompt boundary override on_set_prompt().
2026-05-21 16:50:07 +08:00 · 2026-05-20 21:15:35 -07:00
11 changed files with 152 additions and 804 deletions
--- a/comfy_api/latest/_caching.py
+++ b/comfy_api/latest/_caching.py
@ -21,6 +21,10 @@ class CacheProvider(ABC):
    Exceptions from provider methods are caught by the caller and never break execution.
    """

+    async def on_set_prompt(self) -> None:
+        """Called after prompt cache keys are prepared. Dispatched via asyncio.create_task."""
+        pass
+
    @abstractmethod
    async def on_lookup(self, context: CacheContext) -> Optional[CacheValue]:
        """Called on local cache miss. Return CacheValue if found, None otherwise."""
--- a/comfy_execution/caching.py
+++ b/comfy_execution/caching.py
@ -164,6 +164,7 @@ class BasicCache:
        await self.cache_key_set.add_keys(node_ids)
        self.is_changed_cache = is_changed_cache
        self.initialized = True
+        await self._notify_providers_set_prompt()

    def all_node_ids(self):
        assert self.initialized
@ -263,6 +264,24 @@ class BasicCache:
            except Exception as e:
                _logger.warning(f"Cache provider {provider.__class__.__name__} error on store: {e}")

+    async def _notify_providers_set_prompt(self):
+        from comfy_execution.cache_provider import (
+            _has_cache_providers, _get_cache_providers, _logger
+        )
+
+        if not self.enable_providers:
+            return
+        if not _has_cache_providers():
+            return
+
+        for provider in _get_cache_providers():
+            try:
+                task = asyncio.create_task(self._safe_provider_set_prompt(provider))
+                self._pending_store_tasks.add(task)
+                task.add_done_callback(self._pending_store_tasks.discard)
+            except Exception as e:
+                _logger.warning(f"Cache provider {provider.__class__.__name__} error on set_prompt: {e}")
+
    @staticmethod
    async def _safe_provider_store(provider, context, cache_value):
        from comfy_execution.cache_provider import _logger
@ -271,6 +290,14 @@ class BasicCache:
        except Exception as e:
            _logger.warning(f"Cache provider {provider.__class__.__name__} async store error: {e}")

+    @staticmethod
+    async def _safe_provider_set_prompt(provider):
+        from comfy_execution.cache_provider import _logger
+        try:
+            await provider.on_set_prompt()
+        except Exception as e:
+            _logger.warning(f"Cache provider {provider.__class__.__name__} async set_prompt error: {e}")
+
    async def _check_providers_lookup(self, node_id, cache_key):
        from comfy_execution.cache_provider import (
            _has_cache_providers, _get_cache_providers,
--- a/comfy_extras/nodes_audio.py
+++ b/comfy_extras/nodes_audio.py
@ -543,7 +543,7 @@ class AudioConcat(IO.ComfyNode):
        return IO.Schema(
            node_id="AudioConcat",
            search_aliases=["join audio", "combine audio", "append audio"],
-            display_name="Concatenate Audio",
+            display_name="Audio Concat",
            description="Concatenates the audio1 to audio2 in the specified direction.",
            category="audio",
            inputs=[
@ -597,7 +597,7 @@ class AudioMerge(IO.ComfyNode):
        return IO.Schema(
            node_id="AudioMerge",
            search_aliases=["mix audio", "overlay audio", "layer audio"],
-            display_name="Merge Audio",
+            display_name="Audio Merge",
            description="Combine two audio tracks by overlaying their waveforms.",
            category="audio",
            inputs=[
@ -667,9 +667,8 @@ class AudioAdjustVolume(IO.ComfyNode):
        return IO.Schema(
            node_id="AudioAdjustVolume",
            search_aliases=["audio gain", "loudness", "audio level"],
-            display_name="Adjust Audio Volume",
+            display_name="Audio Adjust Volume",
            category="audio",
-            description="Adjust the volume of the audio by a specified amount in decibels (dB).",
            inputs=[
                IO.Audio.Input("audio"),
                IO.Int.Input(
--- a/comfy_extras/nodes_dataset.py
+++ b/comfy_extras/nodes_dataset.py
@ -47,10 +47,8 @@ class LoadImageDataSetFromFolderNode(io.ComfyNode):
    def define_schema(cls):
        return io.Schema(
            node_id="LoadImageDataSetFromFolder",
-            search_aliases=["load folder", "load from folder", "load dataset", "load images", "import dataset"],
-            display_name="Load Image (from Folder)",
-            category="image",
-            description="Load a dataset of images from a specified folder and return a list of images. Supported formats: PNG, JPG, JPEG, WEBP.",
+            display_name="Load Image Dataset from Folder",
+            category="dataset",
            is_experimental=True,
            inputs=[
                io.Combo.Input(
@ -86,16 +84,14 @@ class LoadImageTextDataSetFromFolderNode(io.ComfyNode):
    def define_schema(cls):
        return io.Schema(
            node_id="LoadImageTextDataSetFromFolder",
-            search_aliases=["load folder", "load from folder", "load dataset", "load images", "import dataset"],
-            display_name="Load Image-Text (from Folder)",
-            category="image",
-            description="Load a dataset of pairs of images and text captions from a specified folder and return them as a list. Supported formats: PNG, JPG, JPEG, WEBP.",
+            display_name="Load Image and Text Dataset from Folder",
+            category="dataset",
            is_experimental=True,
            inputs=[
                io.Combo.Input(
                    "folder",
                    options=folder_paths.get_input_subfolders(),
-                    tooltip="The folder to load images and text captions from.",
+                    tooltip="The folder to load images from.",
                )
            ],
            outputs=[
@ -210,10 +206,8 @@ class SaveImageDataSetToFolderNode(io.ComfyNode):
    def define_schema(cls):
        return io.Schema(
            node_id="SaveImageDataSetToFolder",
-            search_aliases=["save folder", "save to folder", "save dataset", "save images", "export dataset"],
-            display_name="Save Image (to Folder) (DEPRECATED)",
-            category="image",
-            description="Save a dataset of images to a specified folder. Supported formats: PNG.",
+            display_name="Save Image Dataset to Folder",
+            category="dataset",
            is_experimental=True,
            is_output_node=True,
            is_input_list=True,  # Receive images as list
@ -232,7 +226,6 @@ class SaveImageDataSetToFolderNode(io.ComfyNode):
                ),
            ],
            outputs=[],
-            is_deprecated=True,  # This node is redundant and superseded by existing Save Image nodes where the target folder can be specified in the filename_prefix
        )

    @classmethod
@ -253,20 +246,14 @@ class SaveImageTextDataSetToFolderNode(io.ComfyNode):
    def define_schema(cls):
        return io.Schema(
            node_id="SaveImageTextDataSetToFolder",
-            search_aliases=["save folder", "save to folder", "save dataset", "save images", "save text", "export dataset"],
-            display_name="Save Image-Text (to Folder)",
-            category="image",
-            description="Save a dataset of pairs of images and text captions to a specified folder. Images are saved as PNG files and captions are saved as TXT files with the same filename_prefix.",
+            display_name="Save Image and Text Dataset to Folder",
+            category="dataset",
            is_experimental=True,
            is_output_node=True,
            is_input_list=True,  # Receive both images and texts as lists
            inputs=[
                io.Image.Input("images", tooltip="List of images to save."),
-                io.String.Input("texts",
-                    optional=True,
-                    force_input=True,
-                    tooltip="List of text captions to save."
-                ),
+                io.String.Input("texts", tooltip="List of text captions to save."),
                io.String.Input(
                    "folder_name",
                    default="dataset",
@ -283,7 +270,7 @@ class SaveImageTextDataSetToFolderNode(io.ComfyNode):
        )

    @classmethod
-    def execute(cls, images, folder_name, filename_prefix, texts=None):
+    def execute(cls, images, texts, folder_name, filename_prefix):
        # Extract scalar values
        folder_name = folder_name[0]
        filename_prefix = filename_prefix[0]
@ -292,12 +279,11 @@ class SaveImageTextDataSetToFolderNode(io.ComfyNode):
        saved_files = save_images_to_folder(images, output_dir, filename_prefix)

        # Save captions
-        if texts:
-            for idx, (filename, caption) in enumerate(zip(saved_files, texts)):
-                caption_filename = filename.replace(".png", ".txt")
-                caption_path = os.path.join(output_dir, caption_filename)
-                with open(caption_path, "w", encoding="utf-8") as f:
-                    f.write(caption)
+        for idx, (filename, caption) in enumerate(zip(saved_files, texts)):
+            caption_filename = filename.replace(".png", ".txt")
+            caption_path = os.path.join(output_dir, caption_filename)
+            with open(caption_path, "w", encoding="utf-8") as f:
+                f.write(caption)

        logging.info(f"Saved {len(saved_files)} images and captions to {output_dir}.")
        return io.NodeOutput()
@ -328,13 +314,11 @@ class ImageProcessingNode(io.ComfyNode):

    Child classes should set:
        node_id: Unique node identifier (required)
-        search_aliases: List of search aliases (optional)
        display_name: Display name (optional, defaults to node_id)
        description: Node description (optional)
        extra_inputs: List of additional io.Input objects beyond "images" (optional)
        is_group_process: None (auto-detect), True (group), or False (individual) (optional)
        is_output_list: True (list output) or False (single output) (optional, default True)
-        is_deprecated: True if the node is deprecated (optional, default False)

    Child classes must implement ONE of:
        _process(cls, image, **kwargs) -> tensor  (for single-item processing)
@ -342,13 +326,12 @@ class ImageProcessingNode(io.ComfyNode):
    """

    node_id = None
-    search_aliases = []
    display_name = None
    description = None
    extra_inputs = []
    is_group_process = None  # None = auto-detect, True/False = explicit
    is_output_list = None  # None = auto-detect based on processing mode
-    is_deprecated = False
+
    @classmethod
    def _detect_processing_mode(cls):
        """Detect whether this node uses group or individual processing.
@ -419,10 +402,8 @@ class ImageProcessingNode(io.ComfyNode):

        return io.Schema(
            node_id=cls.node_id,
-            search_aliases=cls.search_aliases,
            display_name=cls.display_name or cls.node_id,
-            category=cls.category,
-            description=cls.description,
+            category="dataset/image",
            is_experimental=True,
            is_input_list=is_group,  # True for group, False for individual
            inputs=inputs,
@ -491,13 +472,11 @@ class TextProcessingNode(io.ComfyNode):

    Child classes should set:
        node_id: Unique node identifier (required)
-        search_aliases: List of search aliases (optional)
        display_name: Display name (optional, defaults to node_id)
        description: Node description (optional)
        extra_inputs: List of additional io.Input objects beyond "texts" (optional)
        is_group_process: None (auto-detect), True (group), or False (individual) (optional)
        is_output_list: True (list output) or False (single output) (optional, default True)
-        is_deprecated: True if the node is deprecated (optional, default False)

    Child classes must implement ONE of:
        _process(cls, text, **kwargs) -> str  (for single-item processing)
@ -505,13 +484,12 @@ class TextProcessingNode(io.ComfyNode):
    """

    node_id = None
-    search_aliases = []
    display_name = None
    description = None
    extra_inputs = []
    is_group_process = None  # None = auto-detect, True/False = explicit
    is_output_list = None  # None = auto-detect based on processing mode
-    is_deprecated = False
+
    @classmethod
    def _detect_processing_mode(cls):
        """Detect whether this node uses group or individual processing.
@ -649,17 +627,15 @@ class TextProcessingNode(io.ComfyNode):

 class ResizeImagesByShorterEdgeNode(ImageProcessingNode):
    node_id = "ResizeImagesByShorterEdge"
-    display_name = "Resize Images by Shorter Edge (DEPRECATED)"
-    category = "image/transform"
-    description = "Resize images so that the shorter edge matches the specified dimension while preserving aspect ratio."
-    is_deprecated = True  # This node is superseded by Resize Image/Mask with resize_type = scale shorter dimension
+    display_name = "Resize Images by Shorter Edge"
+    description = "Resize images so that the shorter edge matches the specified length while preserving aspect ratio."
    extra_inputs = [
        io.Int.Input(
            "shorter_edge",
            default=512,
            min=1,
            max=8192,
-            tooltip="Target dimension for the shorter edge.",
+            tooltip="Target length for the shorter edge.",
        ),
    ]

@ -679,17 +655,15 @@ class ResizeImagesByShorterEdgeNode(ImageProcessingNode):

 class ResizeImagesByLongerEdgeNode(ImageProcessingNode):
    node_id = "ResizeImagesByLongerEdge"
-    display_name = "Resize Images by Longer Edge (DEPRECATED)"
-    category = "image/transform"
-    description = "Resize images so that the longer edge matches the specified dimension while preserving aspect ratio."
-    is_deprecated = True  # This node is superseded by Resize Image/Mask with resize_type = scale longer dimension
+    display_name = "Resize Images by Longer Edge"
+    description = "Resize images so that the longer edge matches the specified length while preserving aspect ratio."
    extra_inputs = [
        io.Int.Input(
            "longer_edge",
            default=1024,
            min=1,
            max=8192,
-            tooltip="Target dimension for the longer edge.",
+            tooltip="Target length for the longer edge.",
        ),
    ]

@ -712,10 +686,8 @@ class ResizeImagesByLongerEdgeNode(ImageProcessingNode):

 class CenterCropImagesNode(ImageProcessingNode):
    node_id = "CenterCropImages"
-    search_aliases=["crop", "cut", "trim"]
-    display_name="Crop Image (Center)"
-    category="image/transform"
-    description = "Center crop an image to the specified dimensions."
+    display_name = "Center Crop Images"
+    description = "Center crop all images to the specified dimensions."
    extra_inputs = [
        io.Int.Input("width", default=512, min=1, max=8192, tooltip="Crop width."),
        io.Int.Input("height", default=512, min=1, max=8192, tooltip="Crop height."),
@ -734,11 +706,10 @@ class CenterCropImagesNode(ImageProcessingNode):

 class RandomCropImagesNode(ImageProcessingNode):
    node_id = "RandomCropImages"
-    search_aliases=["crop", "cut", "trim"]
-    display_name = "Crop Image (Random)"
-    category="image/transform"
-    description = "Randomly crop an image to the specified dimensions."
-
+    display_name = "Random Crop Images"
+    description = (
+        "Randomly crop all images to the specified dimensions (for data augmentation)."
+    )
    extra_inputs = [
        io.Int.Input("width", default=512, min=1, max=8192, tooltip="Crop width."),
        io.Int.Input("height", default=512, min=1, max=8192, tooltip="Crop height."),
@ -763,9 +734,7 @@ class RandomCropImagesNode(ImageProcessingNode):

 class NormalizeImagesNode(ImageProcessingNode):
    node_id = "NormalizeImages"
-    search_aliases=["normalize", "normalize colors"]
-    display_name = "Normalize Image Colors"
-    category = "image/color"
+    display_name = "Normalize Images"
    description = "Normalize images using mean and standard deviation."
    extra_inputs = [
        io.Float.Input(
@ -793,10 +762,8 @@ class NormalizeImagesNode(ImageProcessingNode):

 class AdjustBrightnessNode(ImageProcessingNode):
    node_id = "AdjustBrightness"
-    search_aliases=["brightness"]
    display_name = "Adjust Brightness"
-    category="image/adjustments"
-    description = "Adjust the brightness of an image."
+    description = "Adjust brightness of all images."
    extra_inputs = [
        io.Float.Input(
            "factor",
@ -814,10 +781,8 @@ class AdjustBrightnessNode(ImageProcessingNode):

 class AdjustContrastNode(ImageProcessingNode):
    node_id = "AdjustContrast"
-    search_aliases=["contrast"]
    display_name = "Adjust Contrast"
-    category="image/adjustments"
-    description = "Adjust the contrast of an image."
+    description = "Adjust contrast of all images."
    extra_inputs = [
        io.Float.Input(
            "factor",
@ -835,10 +800,8 @@ class AdjustContrastNode(ImageProcessingNode):

 class ShuffleDatasetNode(ImageProcessingNode):
    node_id = "ShuffleDataset"
-    search_aliases=["shuffle", "randomize", "mix"]
-    display_name = "Shuffle Images List"
-    category = "image/batch"
-    description = "Randomly shuffle the order of images in a list."
+    display_name = "Shuffle Image Dataset"
+    description = "Randomly shuffle the order of images in the dataset."
    is_group_process = True  # Requires full list to shuffle
    extra_inputs = [
        io.Int.Input(
@ -860,15 +823,13 @@ class ShuffleImageTextDatasetNode(io.ComfyNode):
    def define_schema(cls):
        return io.Schema(
            node_id="ShuffleImageTextDataset",
-            search_aliases=["shuffle", "randomize", "mix"],
-            display_name = "Shuffle Pairs of Image-Text",
-            category = "image/batch",
-            description = "Randomly shuffle the order of pairs of image-text in a list.",
+            display_name="Shuffle Image-Text Dataset",
+            category="dataset/image",
            is_experimental=True,
            is_input_list=True,
            inputs=[
                io.Image.Input("images", tooltip="List of images to shuffle."),
-                io.String.Input("texts", tooltip="List of texts to shuffle.", force_input=True),
+                io.String.Input("texts", tooltip="List of texts to shuffle."),
                io.Int.Input(
                    "seed",
                    default=0,
@ -904,11 +865,8 @@ class ShuffleImageTextDatasetNode(io.ComfyNode):

 class TextToLowercaseNode(TextProcessingNode):
    node_id = "TextToLowercase"
-    search_aliases=["lowercase"]
-    display_name = "Convert Text to Lowercase (DEPRECATED)"
-    category = "text"
-    description = "Convert text to lowercase."
-    is_deprecated = True  # This node is superseded by the Convert Text Case node
+    display_name = "Text to Lowercase"
+    description = "Convert all texts to lowercase."

    @classmethod
    def _process(cls, text):
@ -917,11 +875,8 @@ class TextToLowercaseNode(TextProcessingNode):

 class TextToUppercaseNode(TextProcessingNode):
    node_id = "TextToUppercase"
-    search_aliases=["uppercase"]
-    display_name = "Convert Text to Uppercase (DEPRECATED)"
-    category = "text"
-    description = "Convert text to uppercase."
-    is_deprecated = True  # This node is superseded by the Convert Text Case node
+    display_name = "Text to Uppercase"
+    description = "Convert all texts to uppercase."

    @classmethod
    def _process(cls, text):
@ -930,10 +885,8 @@ class TextToUppercaseNode(TextProcessingNode):

 class TruncateTextNode(TextProcessingNode):
    node_id = "TruncateText"
-    search_aliases=["truncate", "cut", "shorten"]
    display_name = "Truncate Text"
-    category = "text"
-    description = "Truncate text to a maximum length."
+    description = "Truncate all texts to a maximum length."
    extra_inputs = [
        io.Int.Input(
            "max_length", default=77, min=1, max=10000, tooltip="Maximum text length."
@ -947,10 +900,8 @@ class TruncateTextNode(TextProcessingNode):

 class AddTextPrefixNode(TextProcessingNode):
    node_id = "AddTextPrefix"
-    display_name = "Add Text Prefix (DEPRECATED)"
-    category = "text"
+    display_name = "Add Text Prefix"
    description = "Add a prefix to all texts."
-    is_deprecated = True  # This node is superseded by the Concatenate Text node
    extra_inputs = [
        io.String.Input("prefix", default="", tooltip="Prefix to add."),
    ]
@ -962,10 +913,8 @@ class AddTextPrefixNode(TextProcessingNode):

 class AddTextSuffixNode(TextProcessingNode):
    node_id = "AddTextSuffix"
-    display_name = "Add Text Suffix (DEPRECATED)"
-    category = "text"
+    display_name = "Add Text Suffix"
    description = "Add a suffix to all texts."
-    is_deprecated = True  # This node is superseded by the Concatenate Text node
    extra_inputs = [
        io.String.Input("suffix", default="", tooltip="Suffix to add."),
    ]
@ -977,10 +926,8 @@ class AddTextSuffixNode(TextProcessingNode):

 class ReplaceTextNode(TextProcessingNode):
    node_id = "ReplaceText"
-    display_name = "Replace Text (DEPRECATED)"
-    category = "text"
+    display_name = "Replace Text"
    description = "Replace text in all texts."
-    is_deprecated = True  # This node is superseded by the other Replace Text node
    extra_inputs = [
        io.String.Input("find", default="", tooltip="Text to find."),
        io.String.Input("replace", default="", tooltip="Text to replace with."),
@ -993,10 +940,8 @@ class ReplaceTextNode(TextProcessingNode):

 class StripWhitespaceNode(TextProcessingNode):
    node_id = "StripWhitespace"
-    display_name = "Strip Whitespace (DEPRECATED)"
-    category = "text"
+    display_name = "Strip Whitespace"
    description = "Strip leading and trailing whitespace from all texts."
-    is_deprecated = True  # This node is superseded by the Trim Text node

    @classmethod
    def _process(cls, text):
@ -1007,13 +952,11 @@ class StripWhitespaceNode(TextProcessingNode):


 class ImageDeduplicationNode(ImageProcessingNode):
-    """Remove duplicate or very similar images from a list using perceptual hashing."""
+    """Remove duplicate or very similar images from the dataset using perceptual hashing."""

    node_id = "ImageDeduplication"
-    search_aliases=["deduplicate", "remove duplicates", "similarity filter"]
-    display_name = "Deduplicate Images"
-    category = "image/batch"
-    description = "Remove duplicate or very similar images from a list."
+    display_name = "Image Deduplication"
+    description = "Remove duplicate or very similar images from the dataset."
    is_group_process = True  # Requires full list to compare images
    extra_inputs = [
        io.Float.Input(
@ -1083,9 +1026,7 @@ class ImageGridNode(ImageProcessingNode):
    """Combine multiple images into a single grid/collage."""

    node_id = "ImageGrid"
-    search_aliases=["grid", "collage", "combine"]
-    display_name = "Make Image Grid"
-    category="image/batch"
+    display_name = "Image Grid"
    description = "Arrange multiple images into a grid layout."
    is_group_process = True  # Requires full list to create grid
    is_output_list = False  # Outputs single grid image
@ -1161,12 +1102,9 @@ class MergeImageListsNode(ImageProcessingNode):
    """Merge multiple image lists into a single list."""

    node_id = "MergeImageLists"
-    search_aliases=["list", "merge list", "make list"]
-    display_name = "Merge Image Lists (DEPRECATED)"
-    category = "image/batch"
+    display_name = "Merge Image Lists"
    description = "Concatenate multiple image lists into one."
    is_group_process = True  # Receives images as list
-    is_deprecated = True  # This node is superseded by the Create List node

    @classmethod
    def _group_process(cls, images):
@ -1181,11 +1119,9 @@ class MergeTextListsNode(TextProcessingNode):
    """Merge multiple text lists into a single list."""

    node_id = "MergeTextLists"
-    display_name = "Merge Text Lists (DEPRECATED)"
-    category = "text"
+    display_name = "Merge Text Lists"
    description = "Concatenate multiple text lists into one."
    is_group_process = True  # Receives texts as list
-    is_deprecated = True  # This node is superseded by the Create List node

    @classmethod
    def _group_process(cls, texts):
@ -1206,10 +1142,8 @@ class ResolutionBucket(io.ComfyNode):
    def define_schema(cls):
        return io.Schema(
            node_id="ResolutionBucket",
-            search_aliases=["bucket by resolution", "group by resolution", "batch by resolution"],
            display_name="Resolution Bucket",
-            category="training",
-            description="Group latents and conditionings into buckets",
+            category="dataset",
            is_experimental=True,
            is_input_list=True,
            inputs=[
@ -1302,8 +1236,7 @@ class MakeTrainingDataset(io.ComfyNode):
            node_id="MakeTrainingDataset",
            search_aliases=["encode dataset"],
            display_name="Make Training Dataset",
-            category="training",
-            description="Encode images with VAE and texts with CLIP to create a training dataset of latents and conditionings.",
+            category="dataset",
            is_experimental=True,
            is_input_list=True,  # images and texts as lists
            inputs=[
@ -1318,7 +1251,6 @@ class MakeTrainingDataset(io.ComfyNode):
                    "texts",
                    optional=True,
                    tooltip="List of text captions. Can be length n (matching images), 1 (repeated for all), or omitted (uses empty string).",
-                    force_input=True
                ),
            ],
            outputs=[
@ -1388,10 +1320,9 @@ class SaveTrainingDataset(io.ComfyNode):
    def define_schema(cls):
        return io.Schema(
            node_id="SaveTrainingDataset",
-            search_aliases=["export dataset", "save dataset"],
+            search_aliases=["export training data"],
            display_name="Save Training Dataset",
-            category="training",
-            description="Save encoded training dataset (latents + conditioning) to disk for efficient loading during training.",
+            category="dataset",
            is_experimental=True,
            is_output_node=True,
            is_input_list=True,  # Receive lists
@ -1493,8 +1424,7 @@ class LoadTrainingDataset(io.ComfyNode):
            node_id="LoadTrainingDataset",
            search_aliases=["import dataset", "training data"],
            display_name="Load Training Dataset",
-            category="training",
-            description="Load encoded training dataset (latents + conditioning) from disk for use in training.",
+            category="dataset",
            is_experimental=True,
            inputs=[
                io.String.Input(
--- a/comfy_extras/nodes_hunyuan3d.py
+++ b/comfy_extras/nodes_hunyuan3d.py
@ -419,17 +419,15 @@ class VoxelToMeshBasic(IO.ComfyNode):
    def define_schema(cls):
        return IO.Schema(
            node_id="VoxelToMeshBasic",
-            display_name="Voxel to Mesh (Basic) (DEPRECATED)",
+            display_name="Voxel to Mesh (Basic)",
            category="3d",
-            description="Converts a voxel grid to a mesh.",
-            is_deprecated=True, # This node is superseded by the Voxel To Mesh node
            inputs=[
                IO.Voxel.Input("voxel"),
                IO.Float.Input("threshold", default=0.6, min=-1.0, max=1.0, step=0.01),
            ],
            outputs=[
                IO.Mesh.Output(),
-            ],
+            ]
        )

    @classmethod
@ -455,10 +453,9 @@ class VoxelToMesh(IO.ComfyNode):
            node_id="VoxelToMesh",
            display_name="Voxel to Mesh",
            category="3d",
-            description="Converts a voxel grid to a mesh.",
            inputs=[
                IO.Voxel.Input("voxel"),
-                IO.Combo.Input("algorithm", options=["surface net", "basic"]),
+                IO.Combo.Input("algorithm", options=["surface net", "basic"], advanced=True),
                IO.Float.Input("threshold", default=0.6, min=-1.0, max=1.0, step=0.01),
            ],
            outputs=[
--- a/comfy_extras/nodes_images.py
+++ b/comfy_extras/nodes_images.py
@ -55,10 +55,9 @@ class ImageCropV2(IO.ComfyNode):
    def define_schema(cls):
        return IO.Schema(
            node_id="ImageCropV2",
-            search_aliases=["crop", "cut", "trim"],
+            search_aliases=["trim"],
            display_name="Crop Image",
            category="image/transform",
-            description = "Crop an image to the specified dimensions.",
            essentials_category="Image Tools",
            has_intermediate_output=True,
            inputs=[
--- a/comfy_extras/nodes_lt_audio.py
+++ b/comfy_extras/nodes_lt_audio.py
@ -11,8 +11,8 @@ class LTXVAudioVAELoader(io.ComfyNode):
    def define_schema(cls) -> io.Schema:
        return io.Schema(
            node_id="LTXVAudioVAELoader",
-            display_name="Load LTXV Audio VAE",
-            category="loaders",
+            display_name="LTXV Audio VAE Loader",
+            category="audio",
            inputs=[
                io.Combo.Input(
                    "ckpt_name",
@ -40,7 +40,7 @@ class LTXVAudioVAEEncode(VAEEncodeAudio):
        return io.Schema(
            node_id="LTXVAudioVAEEncode",
            display_name="LTXV Audio VAE Encode",
-            category="latent/audio",
+            category="audio",
            inputs=[
                io.Audio.Input("audio", tooltip="The audio to be encoded."),
                io.Vae.Input(
@ -63,7 +63,7 @@ class LTXVAudioVAEDecode(io.ComfyNode):
        return io.Schema(
            node_id="LTXVAudioVAEDecode",
            display_name="LTXV Audio VAE Decode",
-            category="latent/audio",
+            category="audio",
            inputs=[
                io.Latent.Input("samples", tooltip="The latent to be decoded."),
                io.Vae.Input(
--- a/comfy_extras/nodes_mediapipe.py
+++ b/comfy_extras/nodes_mediapipe.py
@ -28,7 +28,7 @@ from comfy_extras.mediapipe.face_landmarker import FaceLandmarker
 from comfy_extras.mediapipe.face_geometry import transformation_matrix_from_detection


-FaceDetectionType = io.Custom("FACE_DETECTION_MODEL")
+FaceLandmarkerType = io.Custom("FACE_LANDMARKER")
 FaceLandmarksType = io.Custom("FACE_LANDMARKS")

 _CANONICAL_KEYS = ("canonical_vertices", "procrustes_indices", "procrustes_weights")
@ -204,19 +204,18 @@ class LoadMediaPipeFaceLandmarker(io.ComfyNode):
    def define_schema(cls):
        return io.Schema(
            node_id="LoadMediaPipeFaceLandmarker",
-            search_aliases=["face", "facial", "mediapipe", "face landmark", "face mesh", "blazeface", "face detection"],
-            display_name="Load Face Detection Model (MediaPipe)",
+            display_name="Load MediaPipe Face Landmarker",
            category="loaders",
            inputs=[
-                io.Combo.Input("model_name", options=folder_paths.get_filename_list("detection"),
-                               tooltip="Face detection model from models/detection/."),
+                io.Combo.Input("model_name", options=folder_paths.get_filename_list("mediapipe"),
+                               tooltip="Face Landmarker safetensors from models/mediapipe/."),
            ],
-            outputs=[FaceDetectionType.Output()],
+            outputs=[FaceLandmarkerType.Output()],
        )

    @classmethod
    def execute(cls, model_name) -> io.NodeOutput:
-        sd = comfy.utils.load_torch_file(folder_paths.get_full_path_or_raise("detection", model_name), safe_load=True)
+        sd = comfy.utils.load_torch_file(folder_paths.get_full_path_or_raise("mediapipe", model_name), safe_load=True)
        wrapper = FaceLandmarkerModel(sd)
        return io.NodeOutput(wrapper)

@ -235,12 +234,10 @@ class MediaPipeFaceLandmarker(io.ComfyNode):
    def define_schema(cls):
        return io.Schema(
            node_id="MediaPipeFaceLandmarker",
-            search_aliases=["face", "facial", "mediapipe", "face landmark", "face mesh", "blazeface", "face detection"],
-            display_name="Detect Face Landmarks (MediaPipe)",
+            display_name="MediaPipe Face Landmarker",
            category="image/detection",
-            description="Detects facial landmarks using MediaPipe model.",
            inputs=[
-                FaceDetectionType.Input("face_detection_model"),
+                FaceLandmarkerType.Input("face_landmarker"),
                io.Image.Input("image"),
                io.Combo.Input("detector_variant", options=["short", "full", "both"], default="short",
                               tooltip="Face detector range. 'short' is tuned for close-up faces "
@ -264,9 +261,9 @@ class MediaPipeFaceLandmarker(io.ComfyNode):
        )

    @classmethod
-    def execute(cls, face_detection_model, image, detector_variant, num_faces, min_confidence,
+    def execute(cls, face_landmarker, image, detector_variant, num_faces, min_confidence,
                missing_frame_fallback) -> io.NodeOutput:
-        canonical = face_detection_model.canonical_data
+        canonical = face_landmarker.canonical_data
        img_np = _image_to_uint8(image)
        B, H, W = img_np.shape[:3]
        chunk = 16
@ -279,7 +276,7 @@ class MediaPipeFaceLandmarker(io.ComfyNode):
            with tqdm(total=B, desc=f"MediaPipe Face Landmarker ({variant})") as tq:
                for i in range(0, B, chunk):
                    end = min(i + chunk, B)
-                    res.extend(face_detection_model.detect_batch(
+                    res.extend(face_landmarker.detect_batch(
                        [img_np[bi] for bi in range(i, end)],
                        num_faces=int(num_faces),
                        score_thresh=float(min_confidence),
@ -309,7 +306,7 @@ class MediaPipeFaceLandmarker(io.ComfyNode):
                per_bb.append({"x": x1, "y": y1, "width": x2 - x1, "height": y2 - y1, "label": "face", "score": float(f["score"])})
            bboxes.append(per_bb)
        return io.NodeOutput({"frames": frames, "image_size": (H, W),
-                              "connection_sets": face_detection_model.connection_sets}, bboxes)
+                              "connection_sets": face_landmarker.connection_sets}, bboxes)


 # Topology keys unioned by the 'all' connections preset (contour parts + irises + nose).
@ -335,10 +332,8 @@ class MediaPipeFaceMeshVisualize(io.ComfyNode):
    def define_schema(cls):
        return io.Schema(
            node_id="MediaPipeFaceMeshVisualize",
-            search_aliases=["face", "facial", "mediapipe", "face landmark", "face mesh", "blazeface", "face detection", "visualize"],
-            display_name="Visualize Face Landmarks (MediaPipe)",
+            display_name="MediaPipe Face Mesh Visualize",
            category="image/detection",
-            description="Draws face landmarks mesh on the input image.",
            inputs=[
                FaceLandmarksType.Input("face_landmarks"),
                io.Image.Input("image", optional=True, tooltip="If not connected, a black canvas will be used."),
@ -448,10 +443,8 @@ class MediaPipeFaceMask(io.ComfyNode):
    def define_schema(cls):
        return io.Schema(
            node_id="MediaPipeFaceMask",
-            search_aliases=["face", "facial", "mediapipe", "face mask", "blazeface", "face detection", "visualize"],
-            display_name="Draw Face Mask (MediaPipe)",
+            display_name="MediaPipe Face Mask",
            category="image/detection",
-            description="Draws a mask from face landmarks.",
            inputs=[
                FaceLandmarksType.Input("face_landmarks"),
                io.DynamicCombo.Input(
--- a/folder_paths.py
+++ b/folder_paths.py
@ -60,7 +60,7 @@ folder_names_and_paths["geometry_estimation"] = ([os.path.join(models_dir, "geom

 folder_names_and_paths["optical_flow"] = ([os.path.join(models_dir, "optical_flow")], supported_pt_extensions)

-folder_names_and_paths["detection"] = ([os.path.join(models_dir, "detection")], supported_pt_extensions)
+folder_names_and_paths["mediapipe"] = ([os.path.join(models_dir, "mediapipe")], supported_pt_extensions)

 output_directory = os.path.join(base_path, "output")
 temp_directory = os.path.join(base_path, "temp")
--- a/models/mediapipe/put_mediapipe_models_here
+++ b/models/mediapipe/put_mediapipe_models_here
--- a/openapi.yaml
+++ b/openapi.yaml
@ -1556,6 +1556,12 @@ paths:
            type: string
            enum: [asc, desc]
          description: Sort direction
+        - name: job_ids
+          in: query
+          schema:
+            type: string
+          x-runtime: [cloud]
+          description: "[cloud-only] Comma-separated UUIDs to filter assets by associated job."
        - name: include_public
          in: query
          schema:
@ -2508,25 +2514,37 @@ paths:

  /api/assets/import:
    post:
-      operationId: importPublishedAssets
+      operationId: importAssets
      tags: [assets]
-      summary: "[cloud-only] Import published assets into the caller's library"
-      description: |
-        [cloud-only] Imports the specified published assets into the caller's asset library. New DB records reference the same storage objects; no file copying occurs. Assets the caller already owns (by hash) are deduplicated. The `id` field on each returned `AssetInfo` is the caller's newly-created private asset ID, not the published asset ID supplied in the request.
+      summary: Import assets from external URLs
+      description: "[cloud-only] Imports one or more assets from external URLs into the cloud asset store."
      x-runtime: [cloud]
      requestBody:
        required: true
        content:
          application/json:
            schema:
-              $ref: "#/components/schemas/ImportPublishedAssetsRequest"
+              type: object
+              required:
+                - imports
+              properties:
+                imports:
+                  type: array
+                  items:
+                    $ref: "#/components/schemas/AssetImportRequest"
+                  description: Assets to import
      responses:
        "200":
-          description: Successfully imported assets
+          description: Import initiated
          content:
            application/json:
              schema:
-                $ref: "#/components/schemas/ImportPublishedAssetsResponse"
+                type: object
+                properties:
+                  assets:
+                    type: array
+                    items:
+                      $ref: "#/components/schemas/Asset"
        "400":
          description: Bad request
          content:
@ -3772,295 +3790,6 @@ paths:
              schema:
                $ref: "#/components/schemas/JwksResponse"

-  # ---------------------------------------------------------------------------
-  # OAuth 2.1 / RFC 7591 Dynamic Client Registration (cloud)
-  # ---------------------------------------------------------------------------
-  /.well-known/oauth-authorization-server:
-    get:
-      operationId: getOAuthAuthorizationServer
-      tags: [auth]
-      summary: "[cloud-only] OAuth 2.1 authorization-server metadata (RFC 8414)"
-      description: "[cloud-only] Public metadata document for OAuth 2.1 clients. Cached 5 minutes."
-      x-runtime: [cloud]
-      security: []
-      responses:
-        "200":
-          description: Authorization-server metadata
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/OAuthAuthorizationServerMetadata"
-        "404":
-          description: OAuth disabled
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/CloudError"
-
-  /.well-known/oauth-protected-resource:
-    get:
-      operationId: getOAuthProtectedResource
-      tags: [auth]
-      summary: "[cloud-only] OAuth 2.1 protected-resource metadata (RFC 9728)"
-      description: "[cloud-only] Public metadata describing the currently advertised protected resource. Cached 5 minutes."
-      x-runtime: [cloud]
-      security: []
-      responses:
-        "200":
-          description: Protected-resource metadata
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/OAuthProtectedResourceMetadata"
-        "404":
-          description: OAuth disabled or no active resource configured
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/CloudError"
-
-  /oauth/authorize:
-    get:
-      operationId: getOAuthAuthorize
-      tags: [auth]
-      summary: "[cloud-only] Begin or resume an OAuth 2.1 authorization request"
-      description: |
-        [cloud-only] Two modes:
-        - **Initial entry** (OAuth params present): validates client/redirect/resource/scopes, persists a server-side authorization-request row, and either redirects (no session / unverified email) to the configured frontend login URL carrying only the opaque `oauth_request_id`, or returns the JSON consent challenge for the frontend to render.
-        - **Resume** (`oauth_request_id` present): loads the server-side row, fails closed if expired/consumed/unknown, returns the JSON consent challenge. Browser-replayed OAuth params are intentionally ignored.
-
-        The frontend renders the consent UI from the JSON payload and POSTs the user's decision back to this endpoint.
-      x-runtime: [cloud]
-      security: []
-      parameters:
-        - { name: response_type,         in: query, required: false, schema: { type: string } }
-        - { name: client_id,             in: query, required: false, schema: { type: string } }
-        - { name: redirect_uri,          in: query, required: false, schema: { type: string } }
-        - { name: scope,                 in: query, required: false, schema: { type: string } }
-        - name: state
-          in: query
-          required: false
-          schema: { type: string }
-          description: |
-            RFC 6749 §10.12 marks `state` as RECOMMENDED. Cloud hardening makes it REQUIRED on the initial-entry path (omitted only on the resume path where `oauth_request_id` is supplied instead). This parameter is `required: false` at the spec level only because the operation is dual-mode (initial entry vs. resume); the runtime rejects empty `state` on the initial-entry path with a stable `invalid_request` 400.
-        - { name: code_challenge,        in: query, required: false, schema: { type: string } }
-        - { name: code_challenge_method, in: query, required: false, schema: { type: string } }
-        - { name: resource,              in: query, required: false, schema: { type: string } }
-        - { name: oauth_request_id,      in: query, required: false, schema: { type: string } }
-      responses:
-        "200":
-          description: Consent challenge payload (session present, email verified). Frontend renders the consent UI from this payload and POSTs back to /oauth/authorize.
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/OAuthConsentChallenge"
-        "302":
-          description: Redirect to login (no session / unverified email) or to registered redirect_uri (pre-validated client error)
-          headers:
-            Location:
-              schema:
-                type: string
-        "400":
-          description: Invalid authorize request (pre-redirect failure — unknown client, redirect mismatch, malformed params)
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/CloudError"
-        "404":
-          description: OAuth disabled
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/CloudError"
-    post:
-      operationId: postOAuthAuthorize
-      tags: [auth]
-      summary: "[cloud-only] Submit OAuth consent decision"
-      description: |
-        [cloud-only] JSON-only consent submission. The handler verifies the per-row CSRF token, atomically marks the authorization request consumed (single-use covers both allow and deny paths), then returns the redirect URL the browser must navigate to. The URL contains either `code` + original `state` for allow, or the RFC 6749 §5.2 error and `state` for deny.
-
-        Workspace membership is re-checked at submission time. Consent is persisted keyed by `(user_id, client_id, resource_id, workspace_id)`; broadening the previously approved scope set requires a fresh consent flow.
-      x-runtime: [cloud]
-      security: []
-      requestBody:
-        required: true
-        content:
-          application/json:
-            schema:
-              type: object
-              required: [oauth_request_id, csrf_token, decision, workspace_id]
-              properties:
-                oauth_request_id: { type: string, format: uuid }
-                csrf_token:       { type: string }
-                decision:         { type: string, enum: [allow, deny] }
-                workspace_id:     { type: string }
-      responses:
-        "200":
-          description: Redirect URL for the frontend to navigate to (allow → with code+state; deny → with error+state)
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/OAuthAuthorizeRedirectResponse"
-        "400":
-          description: Bad request (CSRF mismatch, expired/consumed request, inaccessible workspace)
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/CloudError"
-        "403":
-          description: Scope broadening on consent re-grant — fresh consent flow required
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/CloudError"
-        "404":
-          description: OAuth disabled
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/CloudError"
-
-  /oauth/token:
-    post:
-      operationId: postOAuthToken
-      tags: [auth]
-      summary: "[cloud-only] Exchange authorization code or refresh token for a resource-bound access token"
-      description: |
-        [cloud-only] OAuth 2.1 token endpoint (RFC 6749 §3.2). Public clients only — `client_secret` is rejected.
-
-        Two grant types are supported:
-        - `authorization_code` — exchanges the code minted by `/oauth/authorize` (with PKCE verifier) for an access token + first refresh token. Single-use; reuse fails closed.
-        - `refresh_token` — rotates the refresh token. Old token immediately invalid; presenting an already-rotated token revokes the entire token family and emits a security metric.
-
-        Both grant types re-validate canonical user state, current workspace membership, and the resource's active flag at every mint. A code or refresh token bound to a deactivated resource fails closed.
-
-        Errors follow RFC 6749 §5.2. Logs never contain raw codes, refresh tokens, or minted tokens.
-
-        Per RFC 6749 §5.1, every 200 and 400 response carries `Cache-Control: no-store` and `Pragma: no-cache` so intermediaries cannot cache token-bearing or state-change-reason responses.
-      x-runtime: [cloud]
-      security: []
-      requestBody:
-        required: true
-        content:
-          application/x-www-form-urlencoded:
-            schema:
-              type: object
-              required: [grant_type, client_id]
-              properties:
-                grant_type:    { type: string, enum: [authorization_code, refresh_token] }
-                client_id:     { type: string }
-                code:          { type: string }
-                redirect_uri:  { type: string }
-                code_verifier: { type: string }
-                refresh_token: { type: string }
-                scope:         { type: string }
-                client_secret: { type: string }
-      responses:
-        "200":
-          description: New token pair
-          headers:
-            Cache-Control:
-              schema:
-                type: string
-              description: 'Always "no-store" per RFC 6749 §5.1'
-            Pragma:
-              schema:
-                type: string
-              description: 'Always "no-cache" per RFC 6749 §5.1'
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/OAuthTokenResponse"
-        "400":
-          description: RFC 6749 §5.2 error
-          headers:
-            Cache-Control:
-              schema:
-                type: string
-              description: 'Always "no-store" per RFC 6749 §5.1'
-            Pragma:
-              schema:
-                type: string
-              description: 'Always "no-cache" per RFC 6749 §5.1'
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/OAuthTokenError"
-        "404":
-          description: OAuth disabled
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/CloudError"
-
-  /oauth/register:
-    post:
-      operationId: postOAuthRegister
-      tags: [auth]
-      summary: "[cloud-only] Dynamic Client Registration (RFC 7591)"
-      description: |
-        [cloud-only] Public, unauthenticated, insert-only RFC 7591 §3.1 client registration. Used by MCP-spec-compliant clients to self-register a public OAuth client without operator involvement.
-
-        Policy:
-
-        - Public clients only — `token_endpoint_auth_method` is forced to `none`. Confidential-client registration is out of scope this phase.
-        - Server-owned `resource_grants`. Caller-supplied `scope` or `resource_grants` is rejected as `invalid_client_metadata` (would be a privilege-escalation surface). Dynamic clients receive the same scopes the active resource publishes.
-        - Application-type-aware redirect URI policy. `application_type=native` accepts loopback (`127.0.0.1`, `::1`, `localhost`) and reverse-DNS-shaped custom schemes; `application_type=web` accepts HTTPS to hosts in an operator-controlled allowlist only. `application_type` is REQUIRED on the request — missing or empty rejects with `invalid_client_metadata`.
-        - Anti-impersonation: reserved client names are rejected from third parties via NFKC-folded compare.
-        - Generated `client_id` carries a stable prefix to distinguish dynamic from seeded clients in audit logs.
-        - Cache-Control: `no-store` on every 201 and 400 response (the response carries fresh credentials and rejection reasons).
-      x-runtime: [cloud]
-      security: []
-      requestBody:
-        required: true
-        content:
-          application/json:
-            schema:
-              $ref: "#/components/schemas/OAuthRegisterRequest"
-      responses:
-        "201":
-          description: Registered. Body echoes the metadata RFC 7591 §3.2.1 requires.
-          headers:
-            Cache-Control:
-              schema:
-                type: string
-              description: 'Always "no-store"'
-            Pragma:
-              schema:
-                type: string
-              description: 'Always "no-cache"'
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/OAuthRegisterResponse"
-        "400":
-          description: RFC 7591 §3.2.2 invalid client metadata
-          headers:
-            Cache-Control:
-              schema:
-                type: string
-              description: 'Always "no-store"'
-            Pragma:
-              schema:
-                type: string
-              description: 'Always "no-cache"'
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/OAuthRegisterError"
-        "404":
-          description: OAuth disabled
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/CloudError"
-        "503":
-          description: No active resource is configured — DCR cannot mint a usable client until an active resource row is seeded.
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/CloudError"
-
  # ---------------------------------------------------------------------------
  # Billing (cloud)
  # ---------------------------------------------------------------------------
@ -7361,35 +7090,24 @@ components:
          type: string
          description: Target path on the runtime filesystem

-    ImportPublishedAssetsRequest:
+    AssetImportRequest:
      type: object
      x-runtime: [cloud]
-      description: "[cloud-only] Request body for importing published assets into the caller's library."
+      description: "[cloud-only] A single asset to import from an external URL."
      required:
-        - published_asset_ids
+        - url
      properties:
-        published_asset_ids:
+        url:
+          type: string
+          format: uri
+          description: URL of the asset to import
+        name:
+          type: string
+          description: Display name for the imported asset
+        tags:
          type: array
-          description: IDs of published assets (inputs and models) to import.
          items:
            type: string
-        share_id:
-          type: string
-          nullable: true
-          description: |
-            Optional. Share ID of the published workflow these assets belong to. When provided (non-null, non-empty): all `published_asset_ids` must belong to this share's workflow version; returns 400 if the share is not found or any asset does not belong to it. When omitted, null, or empty string: no share-scoped validation is performed and the assets are validated only against global rules (preserved for clients that have not yet adopted `share_id`).
-
-    ImportPublishedAssetsResponse:
-      type: object
-      x-runtime: [cloud]
-      description: "[cloud-only] Response after importing published assets. Each returned `AssetInfo.id` is the caller's newly-created private asset ID, not the published asset ID supplied in the request."
-      required:
-        - assets
-      properties:
-        assets:
-          type: array
-          items:
-            $ref: "#/components/schemas/AssetInfo"

    RemoteAssetMetadata:
      type: object
@ -7706,325 +7424,6 @@ components:
                description: RSA exponent (base64url)
            additionalProperties: true

-    OAuthAuthorizationServerMetadata:
-      type: object
-      x-runtime: [cloud]
-      description: "[cloud-only] OAuth 2.1 authorization-server metadata (RFC 8414)."
-      required:
-        - issuer
-        - authorization_endpoint
-        - token_endpoint
-        - jwks_uri
-        - response_types_supported
-        - grant_types_supported
-        - code_challenge_methods_supported
-        - token_endpoint_auth_methods_supported
-      properties:
-        issuer:
-          type: string
-          format: uri
-        authorization_endpoint:
-          type: string
-          format: uri
-        token_endpoint:
-          type: string
-          format: uri
-        jwks_uri:
-          type: string
-          format: uri
-        registration_endpoint:
-          type: string
-          format: uri
-          description: "[cloud-only] RFC 7591 §3.1 Dynamic Client Registration endpoint. Advertised so MCP-spec-compliant clients can auto-discover and self-register without operator involvement. Present only when DCR is enabled."
-        response_types_supported:
-          type: array
-          items:
-            type: string
-        grant_types_supported:
-          type: array
-          items:
-            type: string
-        code_challenge_methods_supported:
-          type: array
-          items:
-            type: string
-        token_endpoint_auth_methods_supported:
-          type: array
-          items:
-            type: string
-        scopes_supported:
-          type: array
-          items:
-            type: string
-
-    OAuthProtectedResourceMetadata:
-      type: object
-      x-runtime: [cloud]
-      description: "[cloud-only] OAuth 2.1 protected-resource metadata (RFC 9728)."
-      required:
-        - resource
-        - authorization_servers
-        - scopes_supported
-      properties:
-        resource:
-          type: string
-          format: uri
-        authorization_servers:
-          type: array
-          items:
-            type: string
-            format: uri
-        scopes_supported:
-          type: array
-          items:
-            type: string
-        bearer_methods_supported:
-          type: array
-          items:
-            type: string
-
-    OAuthConsentChallenge:
-      type: object
-      x-runtime: [cloud]
-      description: "[cloud-only] Server-side state describing the OAuth consent decision the user is being asked to make. Returned by GET /oauth/authorize when a valid session exists; the frontend renders the consent UI from this payload and POSTs the decision back. Browser never sees the original OAuth params on resume."
-      required:
-        - oauth_request_id
-        - csrf_token
-        - client_display_name
-        - resource_display_name
-        - scopes
-        - workspaces
-      properties:
-        oauth_request_id:
-          type: string
-          format: uuid
-          description: Opaque server-side identifier for the authorization-request row. Carried back unchanged in the consent submission.
-        csrf_token:
-          type: string
-          description: Per-row CSRF token bound to this authorization request (not to the session). Must be echoed back on POST.
-        client_display_name:
-          type: string
-          description: Human-readable name of the OAuth client requesting authorization.
-        resource_display_name:
-          type: string
-          description: Human-readable name of the protected resource.
-        scopes:
-          type: array
-          description: Scopes the client is requesting for this resource. The frontend should present these for the user to approve.
-          items:
-            type: string
-        workspaces:
-          type: array
-          description: Workspaces the user can select from. Membership is re-checked on POST.
-          items:
-            $ref: "#/components/schemas/OAuthConsentChallengeWorkspace"
-
-    OAuthConsentChallengeWorkspace:
-      type: object
-      x-runtime: [cloud]
-      description: "[cloud-only] One workspace option presented in the OAuth consent challenge."
-      required: [id, name, type, role]
-      properties:
-        id:   { type: string }
-        name: { type: string }
-        type: { type: string, enum: [personal, team] }
-        role: { type: string, enum: [owner, member] }
-
-    OAuthAuthorizeRedirectResponse:
-      type: object
-      x-runtime: [cloud]
-      description: "[cloud-only] Redirect target produced after a JSON consent submission. The frontend must navigate the browser to this URL so custom-scheme client callbacks work without relying on fetch-visible 302 headers."
-      required:
-        - redirect_url
-      properties:
-        redirect_url:
-          type: string
-          format: uri
-          description: OAuth client redirect URI with either code+state for allow, or error+state for deny.
-
-    OAuthTokenResponse:
-      type: object
-      x-runtime: [cloud]
-      description: "[cloud-only] RFC 6749 §5.1 successful token response."
-      required: [access_token, token_type, expires_in, refresh_token, scope]
-      properties:
-        access_token:
-          type: string
-          description: Resource-bound access token (audience matches the protected resource).
-        token_type:
-          type: string
-          enum: [Bearer]
-        expires_in:
-          type: integer
-          description: Access token lifetime in seconds.
-        refresh_token:
-          type: string
-          description: Opaque refresh token. Rotates on every successful refresh; presenting an already-rotated token revokes the entire family.
-        scope:
-          type: string
-          description: Space-delimited scopes granted with this token.
-
-    OAuthTokenError:
-      type: object
-      x-runtime: [cloud]
-      description: "[cloud-only] RFC 6749 §5.2 error response."
-      required: [error]
-      properties:
-        error:
-          type: string
-          description: 'RFC 6749 §5.2 error code: invalid_request, invalid_client, invalid_grant, unauthorized_client, unsupported_grant_type, invalid_scope.'
-        error_description:
-          type: string
-          description: Human-readable, no leak of internal storage state.
-
-    OAuthRegisterRequest:
-      type: object
-      x-runtime: [cloud]
-      additionalProperties: false
-      description: "[cloud-only] RFC 7591 §2 client metadata document. Only the fields the server honors are listed; presence of `scope` or `resource_grants` in the request is rejected (`invalid_client_metadata`) because those are server-owned for dynamic clients."
-      required:
-        - redirect_uris
-        - application_type
-      properties:
-        redirect_uris:
-          type: array
-          items:
-            type: string
-          minItems: 1
-          maxItems: 5
-          description: 1–5 redirect URIs. Validated against `application_type` policy.
-        client_name:
-          type: string
-          maxLength: 100
-          description: Human-readable name shown in the consent UI. Reserved-name list rejects impersonation of major clients.
-        application_type:
-          type: string
-          enum: [native, web]
-          description: |
-            RFC 7591 §2 application_type. **REQUIRED** — clients MUST declare intent; the server does not default this field. `native` for desktop / CLI / MCP-spec-strict clients (loopback redirects); `web` for hosted clients (HTTPS only, host must be allowlisted). A missing or explicitly empty `application_type` rejects with `invalid_client_metadata`.
-        token_endpoint_auth_method:
-          type: string
-          enum: [none]
-          description: 'Public clients only this phase — must be `none` if present. The server forces `none` regardless.'
-        grant_types:
-          type: array
-          items:
-            type: string
-            enum: [authorization_code, refresh_token]
-          description: Optional. Defaults to `["authorization_code","refresh_token"]`.
-        response_types:
-          type: array
-          items:
-            type: string
-            enum: [code]
-          description: Optional. Defaults to `["code"]`.
-        scope:
-          type: string
-          nullable: true
-          description: "**REJECTED IF PRESENT.** Dynamic clients do not pick scopes — the server assigns scopes from the active resource's published list. Sending `scope` in the registration body is treated as a privilege-escalation attempt and returns `invalid_client_metadata`."
-        resource_grants:
-          type: object
-          nullable: true
-          additionalProperties:
-            type: array
-            items:
-              type: string
-          description: "**REJECTED IF PRESENT.** Same reason as `scope`. The set of resources and scopes a dynamic client may request is server-policy, not request-driven."
-        client_uri:
-          type: string
-          nullable: true
-          description: "**REJECTED IF PRESENT.** Unsupported RFC 7591 metadata for this public-client phase."
-        logo_uri:
-          type: string
-          nullable: true
-          description: "**REJECTED IF PRESENT.** Unsupported RFC 7591 metadata for this public-client phase."
-        tos_uri:
-          type: string
-          nullable: true
-          description: "**REJECTED IF PRESENT.** Unsupported RFC 7591 metadata for this public-client phase."
-        policy_uri:
-          type: string
-          nullable: true
-          description: "**REJECTED IF PRESENT.** Unsupported RFC 7591 metadata for this public-client phase."
-        software_id:
-          type: string
-          nullable: true
-          description: "**REJECTED IF PRESENT.** Unsupported RFC 7591 metadata for this public-client phase."
-        software_version:
-          type: string
-          nullable: true
-          description: "**REJECTED IF PRESENT.** Unsupported RFC 7591 metadata for this public-client phase."
-        contacts:
-          type: array
-          nullable: true
-          items:
-            type: string
-          description: "**REJECTED IF PRESENT.** Unsupported RFC 7591 metadata for this public-client phase."
-        jwks:
-          type: object
-          nullable: true
-          additionalProperties: true
-          description: "**REJECTED IF PRESENT.** Unsupported RFC 7591 metadata for this public-client phase."
-        jwks_uri:
-          type: string
-          nullable: true
-          description: "**REJECTED IF PRESENT.** Unsupported RFC 7591 metadata for this public-client phase."
-
-    OAuthRegisterResponse:
-      type: object
-      x-runtime: [cloud]
-      description: "[cloud-only] RFC 7591 §3.2.1 successful registration response."
-      required:
-        - client_id
-        - client_id_issued_at
-        - redirect_uris
-        - grant_types
-        - response_types
-        - token_endpoint_auth_method
-        - application_type
-      properties:
-        client_id:
-          type: string
-          description: Server-generated client_id.
-        client_id_issued_at:
-          type: integer
-          format: int64
-          description: Unix timestamp (seconds) when the client was registered.
-        client_name:
-          type: string
-        redirect_uris:
-          type: array
-          items:
-            type: string
-        grant_types:
-          type: array
-          items:
-            type: string
-        response_types:
-          type: array
-          items:
-            type: string
-        token_endpoint_auth_method:
-          type: string
-          enum: [none]
-        application_type:
-          type: string
-          enum: [native, web]
-
-    OAuthRegisterError:
-      type: object
-      x-runtime: [cloud]
-      description: "[cloud-only] RFC 7591 §3.2.2 error response."
-      required:
-        - error
-      properties:
-        error:
-          type: string
-          enum: [invalid_redirect_uri, invalid_client_metadata]
-        error_description:
-          type: string
-          nullable: true
-
    BillingBalance:
      type: object
      x-runtime: [cloud]