INNER CODE UNIT · Python
queue_workflow
runpod-workers/worker-comfyui · handler.py:642
def queue_workflow(workflow, client_id, comfy_org_api_key=None):
"""
Queue a workflow to be processed by ComfyUI
Args:
workflow (dict): A dictionary containing the workflow to be processed
client_id (str): The client ID for the websocket connection
comfy_org_api_key (str, optional): Comfy.org API key for API Nodes
Returns:
dict: The JSON response from ComfyUI after processing the workflow
Raises:
ValueError: If the workflow validation fails with detailed error information
"""
# Include client_id in the prompt payload
payload = {"prompt": workflow, "client_id": client_id}