nodes/numz-Comfyui-FlowChain
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

filter workflows list

Browse Source
This commit is contained in:
NumZ
2025-03-28 06:18:38 +01:00
parent 2a3d4a2bbb
commit a47b23e65b
2 changed files with 27 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files
py/endpoints.py
+26 -21
View File
@@ -10,24 +10,24 @@ def get_workflow_data(workflow_file):
nodes_input = {}
nodes_output = {}
if "nodes" in workflow_file:
# Extraire les nœuds WorkflowInput et WorkflowOutput
for node in workflow_file["nodes"]:
if node.get("type") == "WorkflowInput":
# Convertir au format compatible pour le client
node_id = str(node.get("id", "unknown"))
nodes_input[node_id] = {
"class_type": "WorkflowInput",
"inputs": node.get("widgets_values", {}),
"position": node.get("pos", {})[1]
}
elif node.get("type") == "WorkflowOutput":
node_id = str(node.get("id", "unknown"))
nodes_output[node_id] = {
"class_type": "WorkflowOutput",
"inputs": node.get("widgets_values", {}),
"position": node.get("pos", {})[1]
}
# Extraire les nœuds WorkflowInput et WorkflowOutput
for node in workflow_file["nodes"]:
if node.get("type") == "WorkflowInput":
# Convertir au format compatible pour le client
node_id = str(node.get("id", "unknown"))
nodes_input[node_id] = {
"class_type": "WorkflowInput",
"inputs": node.get("widgets_values", {}),
"position": node.get("pos", {})[1]
}
elif node.get("type") == "WorkflowOutput":
node_id = str(node.get("id", "unknown"))
nodes_output[node_id] = {
"class_type": "WorkflowOutput",
"inputs": node.get("widgets_values", {}),
"position": node.get("pos", {})[1]
}
# sort by position
nodes_input = dict(sorted(nodes_input.items(), key=lambda item: item[1]["position"]))
nodes_output = dict(sorted(nodes_output.items(), key=lambda item: item[1]["position"]))
@@ -58,7 +58,10 @@ async def workflows(request):
with open(file_path, "r", encoding="utf-8") as f:
json_content = json.load(f)
relative_path = os.path.relpath(file_path, str(json_path))
result[relative_path] = get_workflow_data(json_content)
if "nodes" in json_content:
file_conf = get_workflow_data(json_content)
if file_conf["inputs"] or file_conf["outputs"]:
result[relative_path] = file_conf
except json.JSONDecodeError:
# Ignorer les fichiers JSON mal formés
@@ -91,8 +94,10 @@ async def workflow(request):
if os.path.exists(json_path):
with open(json_path, "r", encoding="utf-8") as f:
json_content = json.load(f)
result = get_workflow_data(json_content)
if "nodes" in json_content:
result = get_workflow_data(json_content)
else:
result = {"error": "File not found"}
else:
result = {"error": "File not found"}
web/js/workflows.js
+1 -1
View File
@@ -27,7 +27,7 @@ async function convertWorkflowToApiFormat(standardWorkflow) {
const originalGraph = app.graph;
// Utiliser graphToPrompt en mode isolé
app.graph = tempGraph;
app.graph = tempGraph;
// Configurer sans déclencher de callbacks
tempGraph.configure(standardWorkflow);