Merge pull request #228 from biggraph/darabos-mcp-example

examples/LynxScribe/ChatAPI/Demo.lynxkite.json

@@ -0,0 +1,1230 @@
+{
+  "edges": [
+    {
+      "id": "MCP: Search web 1 output Agent 1 tools",
+      "source": "MCP: Search web 1",
+      "sourceHandle": "output",
+      "target": "Agent 1",
+      "targetHandle": "tools"
+    },
+    {
+      "id": "Agent 1 output Agent 2 tools",
+      "source": "Agent 1",
+      "sourceHandle": "output",
+      "target": "Agent 2",
+      "targetHandle": "tools"
+    },
+    {
+      "id": "Database 1 output MCP: Query database with SQL 2 db",
+      "source": "Database 1",
+      "sourceHandle": "output",
+      "target": "MCP: Query database with SQL 2",
+      "targetHandle": "db"
+    },
+    {
+      "id": "MCP: Query database with SQL 2 output Agent 1 tools",
+      "source": "MCP: Query database with SQL 2",
+      "sourceHandle": "output",
+      "target": "Agent 1",
+      "targetHandle": "tools"
+    },
+    {
+      "id": "Agent 3 output Agent 2 tools",
+      "source": "Agent 3",
+      "sourceHandle": "output",
+      "target": "Agent 2",
+      "targetHandle": "tools"
+    },
+    {
+      "id": "MCP: Calculator 1 output Agent 1 tools",
+      "source": "MCP: Calculator 1",
+      "sourceHandle": "output",
+      "target": "Agent 1",
+      "targetHandle": "tools"
+    },
+    {
+      "id": "Agent 2 output Chat frontend 1 agent",
+      "source": "Agent 2",
+      "sourceHandle": "output",
+      "target": "Chat frontend 1",
+      "targetHandle": "agent"
+    },
+    {
+      "id": "Ladder graph 1 output PageRank 1 G",
+      "source": "Ladder graph 1",
+      "sourceHandle": "output",
+      "target": "PageRank 1",
+      "targetHandle": "G"
+    },
+    {
+      "id": "PageRank 1 output Database 1 data_pipeline",
+      "source": "PageRank 1",
+      "sourceHandle": "output",
+      "target": "Database 1",
+      "targetHandle": "data_pipeline"
+    },
+    {
+      "id": "Karate club graph 1 output Common neighbor centrality 1 G",
+      "source": "Karate club graph 1",
+      "sourceHandle": "output",
+      "target": "Common neighbor centrality 1",
+      "targetHandle": "G"
+    },
+    {
+      "id": "Common neighbor centrality 1 output Database 1 data_pipeline",
+      "source": "Common neighbor centrality 1",
+      "sourceHandle": "output",
+      "target": "Database 1",
+      "targetHandle": "data_pipeline"
+    },
+    {
+      "id": "Import file 1 output SQL 1 bundle",
+      "source": "Import file 1",
+      "sourceHandle": "output",
+      "target": "SQL 1",
+      "targetHandle": "bundle"
+    },
+    {
+      "id": "SQL 1 output SQL 2 bundle",
+      "source": "SQL 1",
+      "sourceHandle": "output",
+      "target": "SQL 2",
+      "targetHandle": "bundle"
+    },
+    {
+      "id": "SQL 2 output Database 1 data_pipeline",
+      "source": "SQL 2",
+      "sourceHandle": "output",
+      "target": "Database 1",
+      "targetHandle": "data_pipeline"
+    },
+    {
+      "id": "MCP: Run ComfyUI workflow 1 output Agent 3 tools",
+      "source": "MCP: Run ComfyUI workflow 1",
+      "sourceHandle": "output",
+      "target": "Agent 3",
+      "targetHandle": "tools"
+    }
+  ],
+  "env": "LynxKite Graph Analytics",
+  "nodes": [
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "Data Science"
+          ],
+          "color": "orange",
+          "doc": null,
+          "id": "Data Science > Database",
+          "inputs": [
+            {
+              "name": "data_pipeline",
+              "position": "left",
+              "type": {
+                "type": "list[lynxkite_graph_analytics.core.Bundle]"
+              }
+            }
+          ],
+          "name": "Database",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "Data Science > Database",
+        "params": {},
+        "status": "done",
+        "title": "Database"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "Database 1",
+      "position": {
+        "x": -175.8708861292469,
+        "y": 465.47762360072204
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "green",
+          "doc": null,
+          "id": "LynxScribe > MCP: Search web",
+          "inputs": [],
+          "name": "MCP: Search web",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": "Google",
+              "name": "engine",
+              "type": {
+                "enum": [
+                  "Google",
+                  "Bing",
+                  "DuckDuckGo"
+                ]
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > MCP: Search web",
+        "params": {
+          "engine": "Google"
+        },
+        "status": "done",
+        "title": "MCP: Search web"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 156.0,
+      "id": "MCP: Search web 1",
+      "position": {
+        "x": 183.63527583294598,
+        "y": 221.47335161357154
+      },
+      "type": "basic",
+      "width": 204.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "blue",
+          "doc": null,
+          "id": "LynxScribe > Agent",
+          "inputs": [
+            {
+              "name": "tools",
+              "position": "bottom",
+              "type": {
+                "type": "list[str]"
+              }
+            }
+          ],
+          "name": "Agent",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": "",
+              "name": "purpose",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            },
+            {
+              "default": "This agent help with various tasks.",
+              "name": "description",
+              "type": {
+                "format": "textarea"
+              }
+            },
+            {
+              "default": "You are a helpful assistant.",
+              "name": "system_prompt",
+              "type": {
+                "format": "textarea"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > Agent",
+        "params": {
+          "description": "This agent can help with data science\nand analytics questions.",
+          "purpose": "Data assistant",
+          "system_prompt": "Using the tools at your disposal answer\nall questions in JSON format."
+        },
+        "status": "done",
+        "title": "Agent"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 351.0,
+      "id": "Agent 1",
+      "position": {
+        "x": -55.2832056082014,
+        "y": -263.46066732045733
+      },
+      "type": "basic",
+      "width": 337.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "blue",
+          "doc": null,
+          "id": "LynxScribe > Agent",
+          "inputs": [
+            {
+              "name": "tools",
+              "position": "bottom",
+              "type": {
+                "type": "list[str]"
+              }
+            }
+          ],
+          "name": "Agent",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": "",
+              "name": "purpose",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            },
+            {
+              "default": "This agent help with various tasks.",
+              "name": "description",
+              "type": {
+                "format": "textarea"
+              }
+            },
+            {
+              "default": "You are a helpful assistant.",
+              "name": "system_prompt",
+              "type": {
+                "format": "textarea"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > Agent",
+        "params": {
+          "description": "",
+          "purpose": "Main conversation",
+          "system_prompt": "You are a helpful assistant. Use the agents at your disposal\nto help the user."
+        },
+        "status": "done",
+        "title": "Agent"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 326.0,
+      "id": "Agent 2",
+      "position": {
+        "x": 226.41731551276598,
+        "y": -695.7509243963451
+      },
+      "type": "basic",
+      "width": 457.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [
+            "NetworkX",
+            "Generators",
+            "Classic"
+          ],
+          "color": "orange",
+          "doc": null,
+          "id": "NetworkX > Generators > Classic > Ladder graph",
+          "inputs": [],
+          "name": "Ladder graph",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "right",
+              "type": {
+                "type": "<class 'networkx.classes.graph.Graph'>"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": null,
+              "name": "n",
+              "type": {
+                "type": "<class 'int'>"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "NetworkX > Generators > Classic > Ladder graph",
+        "params": {
+          "n": "11"
+        },
+        "status": "done",
+        "title": "Ladder graph"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "Ladder graph 1",
+      "position": {
+        "x": -1297.4471345569843,
+        "y": 364.99969784589774
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "green",
+          "doc": null,
+          "id": "LynxScribe > MCP: Query database with SQL",
+          "inputs": [
+            {
+              "name": "db",
+              "position": "bottom",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            }
+          ],
+          "name": "MCP: Query database with SQL",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > MCP: Query database with SQL",
+        "params": {},
+        "status": "done",
+        "title": "MCP: Query database with SQL"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 152.0,
+      "id": "MCP: Query database with SQL 2",
+      "position": {
+        "x": -248.451978071668,
+        "y": 231.5655840074671
+      },
+      "type": "basic",
+      "width": 334.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "blue",
+          "doc": null,
+          "id": "LynxScribe > Agent",
+          "inputs": [
+            {
+              "name": "tools",
+              "position": "bottom",
+              "type": {
+                "type": "list[str]"
+              }
+            }
+          ],
+          "name": "Agent",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": "",
+              "name": "purpose",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            },
+            {
+              "default": "This agent help with various tasks.",
+              "name": "description",
+              "type": {
+                "format": "textarea"
+              }
+            },
+            {
+              "default": "You are a helpful assistant.",
+              "name": "system_prompt",
+              "type": {
+                "format": "textarea"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > Agent",
+        "params": {
+          "description": "This agent can help with\nimage generation tasks.",
+          "purpose": "Generate image",
+          "system_prompt": "Formulate a good image generation prompt\nand use the ComfyUI tool to generate\nan image according to the user's wishes."
+        },
+        "status": "done",
+        "title": "Agent"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 392.0,
+      "id": "Agent 3",
+      "position": {
+        "x": 511.2723643375159,
+        "y": -276.6461006767206
+      },
+      "type": "basic",
+      "width": 368.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "green",
+          "doc": null,
+          "id": "LynxScribe > MCP: Calculator",
+          "inputs": [],
+          "name": "MCP: Calculator",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > MCP: Calculator",
+        "params": {},
+        "status": "done",
+        "title": "MCP: Calculator"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "MCP: Calculator 1",
+      "position": {
+        "x": -527.6679408294542,
+        "y": 240.503939070944
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "collapsed": false,
+        "display": {
+          "dataframes": {
+            "service": {
+              "columns": [
+                "url"
+              ],
+              "data": [
+                [
+                  "/api/service/lynxkite_graph_analytics/LynxScribe MCP/Demo.lynxkite.json/Chat frontend 1"
+                ]
+              ]
+            }
+          }
+        },
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "gray",
+          "doc": null,
+          "id": "LynxScribe > Chat frontend",
+          "inputs": [
+            {
+              "name": "agent",
+              "position": "bottom",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            }
+          ],
+          "name": "Chat frontend",
+          "outputs": [],
+          "params": [],
+          "type": "service"
+        },
+        "op_id": "LynxScribe > Chat frontend",
+        "params": {},
+        "status": "done",
+        "title": "Chat frontend"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 362.0,
+      "id": "Chat frontend 1",
+      "position": {
+        "x": 237.184571561771,
+        "y": -1107.6739000139528
+      },
+      "type": "service",
+      "width": 428.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "NetworkX",
+            "Algorithms",
+            "Link analysis",
+            "PageRank alg"
+          ],
+          "color": "orange",
+          "doc": null,
+          "id": "NetworkX > Algorithms > Link analysis > PageRank alg > PageRank",
+          "inputs": [
+            {
+              "name": "G",
+              "position": "left",
+              "type": {
+                "type": "<class 'networkx.classes.graph.Graph'>"
+              }
+            }
+          ],
+          "name": "PageRank",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "right",
+              "type": {
+                "type": "<class 'networkx.classes.graph.Graph'>"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": "0.85",
+              "name": "alpha",
+              "type": {
+                "type": "float | None"
+              }
+            },
+            {
+              "default": "100",
+              "name": "max_iter",
+              "type": {
+                "type": "int | None"
+              }
+            },
+            {
+              "default": "1e-06",
+              "name": "tol",
+              "type": {
+                "type": "float | None"
+              }
+            },
+            {
+              "default": "weight",
+              "name": "weight",
+              "type": {
+                "type": "str | None"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "NetworkX > Algorithms > Link analysis > PageRank alg > PageRank",
+        "params": {
+          "alpha": "0.85",
+          "max_iter": "100",
+          "tol": "1e-06",
+          "weight": "weight"
+        },
+        "status": "done",
+        "title": "PageRank"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "PageRank 1",
+      "position": {
+        "x": -878.5796659405156,
+        "y": 369.96445264090244
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [
+            "NetworkX",
+            "Generators",
+            "Social"
+          ],
+          "color": "orange",
+          "doc": null,
+          "id": "NetworkX > Generators > Social > Karate club graph",
+          "inputs": [],
+          "name": "Karate club graph",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "right",
+              "type": {
+                "type": "<class 'networkx.classes.graph.Graph'>"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "NetworkX > Generators > Social > Karate club graph",
+        "params": {},
+        "status": "done",
+        "title": "Karate club graph"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "Karate club graph 1",
+      "position": {
+        "x": -1304.6391517192224,
+        "y": 585.0242219568652
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "NetworkX",
+            "Algorithms",
+            "Link prediction"
+          ],
+          "color": "orange",
+          "doc": null,
+          "id": "NetworkX > Algorithms > Link prediction > Common neighbor centrality",
+          "inputs": [
+            {
+              "name": "G",
+              "position": "left",
+              "type": {
+                "type": "<class 'networkx.classes.graph.Graph'>"
+              }
+            }
+          ],
+          "name": "Common neighbor centrality",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "right",
+              "type": {
+                "type": "<class 'networkx.classes.graph.Graph'>"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "NetworkX > Algorithms > Link prediction > Common neighbor centrality",
+        "params": {},
+        "status": "done",
+        "title": "Common neighbor centrality"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 130.0,
+      "id": "Common neighbor centrality 1",
+      "position": {
+        "x": -990.2453153930347,
+        "y": 587.3192401780905
+      },
+      "type": "basic",
+      "width": 341.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [],
+          "color": "orange",
+          "doc": [
+            {
+              "kind": "text",
+              "value": "Read the contents of the a file into a `Bundle`."
+            },
+            {
+              "kind": "parameters",
+              "value": [
+                {
+                  "annotation": "str",
+                  "description": "Path to the file to import.",
+                  "name": "file_path"
+                },
+                {
+                  "annotation": "str",
+                  "description": "Name to use for identifying the table in the bundle.",
+                  "name": "table_name"
+                },
+                {
+                  "annotation": "FileFormat",
+                  "description": "Format of the file. Has to be one of the values in the `FileFormat` enum.",
+                  "name": "file_format"
+                }
+              ]
+            },
+            {
+              "kind": "returns",
+              "value": [
+                {
+                  "annotation": "<class 'lynxkite_graph_analytics.core.Bundle'>",
+                  "description": "Bundle with a single table with the contents of the file.",
+                  "name": "Bundle"
+                }
+              ]
+            }
+          ],
+          "id": "Import file",
+          "inputs": [],
+          "name": "Import file",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "right",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": null,
+              "name": "file_path",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            },
+            {
+              "default": null,
+              "name": "table_name",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            },
+            {
+              "default": "csv",
+              "name": "file_format",
+              "type": {
+                "enum": [
+                  "csv",
+                  "parquet",
+                  "json",
+                  "excel"
+                ]
+              }
+            },
+            {
+              "default": "csv",
+              "groups": {
+                "csv": [
+                  {
+                    "default": "<from file>",
+                    "name": "columns",
+                    "type": {
+                      "type": "<class 'str'>"
+                    }
+                  },
+                  {
+                    "default": "<auto>",
+                    "name": "separator",
+                    "type": {
+                      "type": "<class 'str'>"
+                    }
+                  }
+                ],
+                "excel": [
+                  {
+                    "default": "Sheet1",
+                    "name": "sheet_name",
+                    "type": {
+                      "type": "<class 'str'>"
+                    }
+                  }
+                ],
+                "json": [],
+                "parquet": []
+              },
+              "name": "file_format_group",
+              "selector": {
+                "default": "csv",
+                "name": "file_format",
+                "type": {
+                  "enum": [
+                    "csv",
+                    "parquet",
+                    "json",
+                    "excel"
+                  ]
+                }
+              },
+              "type": "group"
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "Import file",
+        "params": {
+          "file_format": "csv",
+          "file_format_group": "csv",
+          "file_path": "uploads/molecules2.csv",
+          "table_name": "molecules"
+        },
+        "status": "done",
+        "title": "Import file"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 393.0,
+      "id": "Import file 1",
+      "position": {
+        "x": -1411.4491034838866,
+        "y": 772.1675932822765
+      },
+      "type": "basic",
+      "width": 369.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {
+            "dataframes": {
+              "molecules": {
+                "columns": [
+                  "name",
+                  "smiles"
+                ],
+                "key": "molecules"
+              }
+            },
+            "other": {},
+            "relations": []
+          }
+        ],
+        "meta": {
+          "categories": [],
+          "color": "orange",
+          "doc": [
+            {
+              "kind": "text",
+              "value": "Run a SQL query on the DataFrames in the bundle. Save the results as a new DataFrame."
+            }
+          ],
+          "id": "SQL",
+          "inputs": [
+            {
+              "name": "bundle",
+              "position": "left",
+              "type": {
+                "type": "<class 'lynxkite_graph_analytics.core.Bundle'>"
+              }
+            }
+          ],
+          "name": "SQL",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "right",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": null,
+              "name": "query",
+              "type": {
+                "format": "textarea"
+              }
+            },
+            {
+              "default": "result",
+              "name": "save_as",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "SQL",
+        "params": {
+          "query": "select *",
+          "save_as": "result"
+        },
+        "status": "done",
+        "title": "SQL"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "SQL 1",
+      "position": {
+        "x": -931.2061769202694,
+        "y": 766.0054007337461
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {
+            "dataframes": {
+              "molecules": {
+                "columns": [
+                  "name",
+                  "smiles"
+                ],
+                "key": "molecules"
+              },
+              "result": {
+                "columns": [],
+                "key": "result"
+              }
+            },
+            "other": {},
+            "relations": []
+          }
+        ],
+        "meta": {
+          "categories": [],
+          "color": "orange",
+          "doc": [
+            {
+              "kind": "text",
+              "value": "Run a SQL query on the DataFrames in the bundle. Save the results as a new DataFrame."
+            }
+          ],
+          "id": "SQL",
+          "inputs": [
+            {
+              "name": "bundle",
+              "position": "left",
+              "type": {
+                "type": "<class 'lynxkite_graph_analytics.core.Bundle'>"
+              }
+            }
+          ],
+          "name": "SQL",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "right",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": null,
+              "name": "query",
+              "type": {
+                "format": "textarea"
+              }
+            },
+            {
+              "default": "result",
+              "name": "save_as",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "SQL",
+        "params": {
+          "query": "select *",
+          "save_as": "result"
+        },
+        "status": "done",
+        "title": "SQL"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "SQL 2",
+      "position": {
+        "x": -633.7783633982368,
+        "y": 767.4541281209835
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "green",
+          "doc": null,
+          "id": "LynxScribe > MCP: Run ComfyUI workflow",
+          "inputs": [],
+          "name": "MCP: Run ComfyUI workflow",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": null,
+              "name": "workflow_name",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > MCP: Run ComfyUI workflow",
+        "params": {
+          "workflow_name": "SDXL"
+        },
+        "status": "done",
+        "title": "MCP: Run ComfyUI workflow"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "MCP: Run ComfyUI workflow 1",
+      "position": {
+        "x": 598.9560131686237,
+        "y": 218.52928063566645
+      },
+      "type": "basic",
+      "width": 200.0
+    }
+  ],
+  "paused": false
+}

examples/LynxScribe/ChatAPI/demo.py

@@ -0,0 +1,119 @@
+import enum
+from lynxkite_core import ops
+from lynxkite_graph_analytics import core
+import fastapi
+from lynxscribe.components.chat.api import ChatAPI
+from lynxscribe.components.rag.rag_chatbot import Mode, RAGChatbot, Scenario, ScenarioSelector
+from lynxscribe.core.llm.base import get_llm_engine
+from lynxscribe.core.models.prompts import ChatCompletionPrompt
+
+lsop = ops.op_registration(
+    "LynxKite Graph Analytics", "LynxScribe", dir="bottom-to-top", color="blue"
+)
+
+dsop = ops.op_registration("LynxKite Graph Analytics", "Data Science")
+
+Placeholder = str
+
+
+@lsop("Chat frontend", color="gray", outputs=[], view="service")
+def chat_frontend(agent: Placeholder):
+    return ChatAPIService(agent)
+
+
+@lsop("Agent")
+def agent(
+    tools: list[Placeholder],
+    *,
+    purpose: str = "",
+    description: ops.LongStr = "This agent helps with various tasks.",
+    system_prompt: ops.LongStr = "You are a helpful assistant.",
+):
+    ts = []
+    for t in tools:
+        t = "\n  ".join(t.split("\n"))
+        ts.append(f"- {t}\n")
+    return f"Agent for {purpose} with {len(tools)} tools:\n{''.join(ts)}"
+
+
+@lsop("MCP: Query database with SQL", color="green")
+def sql_tool(db: Placeholder):
+    return f"SQL over {db}"
+
+
+@ops.output_position(output="top")
+@dsop("Database")
+def db(data_pipeline: list[core.Bundle]):
+    return f"DB with {len(data_pipeline)} bundles"
+
+
+class MCPSearchEngine(str, enum.Enum):
+    Google = "Google"
+    Bing = "Bing"
+    DuckDuckGo = "DuckDuckGo"
+
+
+@lsop("MCP: Search web", color="green")
+def web_search(*, engine: MCPSearchEngine = MCPSearchEngine.Google):
+    return f"Web search ({engine.name})"
+
+
+@lsop("MCP: Run ComfyUI workflow", color="green")
+def run_comfyui_workflow(*, workflow_name: str):
+    return f"Run comfyui workflow ({workflow_name})"
+
+
+@lsop("MCP: Calculator", color="green")
+def calculator():
+    return "Calculator"
+
+
+class ChatAPIService:
+    def __init__(self, agent: str):
+        self.agent = agent
+        self.chat_api = ChatAPI(
+            chatbot=RAGChatbot(
+                None,
+                ScenarioSelector([Scenario(name="single", mode=Mode.LLM_ONLY)]),
+                llm=get_llm_engine(name="openai"),
+            ),
+            model="gpt-4o-mini",
+        )
+
+    async def get(self, request: fastapi.Request) -> dict:
+        if request.state.remaining_path == "models":
+            return {
+                "object": "list",
+                "data": [
+                    {
+                        "id": "LynxScribe",
+                        "object": "model",
+                        "created": 0,
+                        "owned_by": "lynxkite",
+                        "meta": {"profile_image_url": "https://lynxkite.com/favicon.png"},
+                    }
+                ],
+            }
+        return {"error": "Not found"}
+
+    async def post(self, request: fastapi.Request) -> dict:
+        if request.state.remaining_path == "chat/completions":
+            request = await request.json()
+            if request["stream"]:
+                from sse_starlette.sse import EventSourceResponse
+
+                return EventSourceResponse(self.stream_chat_api_response(request))
+            else:
+                return await self.get_chat_api_response(request)
+        return {"error": "Not found"}
+
+    async def stream_chat_api_response(self, request):
+        request = ChatCompletionPrompt(**request)
+        async for chunk in await self.chat_api.answer(request, stream=True):
+            chunk.choices[0].delta.content += f"({self.agent})"
+            yield chunk.model_dump_json()
+
+    async def get_chat_api_response(self, request):
+        request = ChatCompletionPrompt(**request)
+        response = await self.chat_api.answer(request, stream=False)
+        return response.model_dump()

examples/LynxScribe/ChatAPI/demo.sh

@@ -0,0 +1,13 @@
+#!/bin/bash -xue
+# xh POST 'https://api.openai.com/v1/chat/completions' \
+#   Authorization:"Bearer $OPENAI_API_KEY" \
+#   model=gpt-4o-mini \
+#   stream:=false \
+#   messages:='[{"role": "user", "content": "what does the fox say"}]'
+
+xh 'http://localhost:8000/api/service/lynxkite_graph_analytics/LynxScribe%20MCP/Demo.lynxkite.json/Chat%20frontend%201/models'
+
+xh POST 'http://localhost:8000/api/service/lynxkite_graph_analytics/LynxScribe%20MCP/Demo.lynxkite.json/Chat%20frontend%201/chat/completions' \
+  model=LynxScribe \
+  stream:=false \
+  messages:='[{"role": "user", "content": "what does the fox say"}]'

examples/LynxScribe/ChatAPI/requirements.txt

@@ -0,0 +1 @@
+../../lynxscribe

examples/LynxScribe/MCP/Demo.lynxkite.json

@@ -0,0 +1,1050 @@
+{
+  "edges": [
+    {
+      "id": "Database 1 output MCP: Query database with SQL 2 db",
+      "source": "Database 1",
+      "sourceHandle": "output",
+      "target": "MCP: Query database with SQL 2",
+      "targetHandle": "db"
+    },
+    {
+      "id": "Ladder graph 1 output PageRank 1 G",
+      "source": "Ladder graph 1",
+      "sourceHandle": "output",
+      "target": "PageRank 1",
+      "targetHandle": "G"
+    },
+    {
+      "id": "PageRank 1 output Database 1 data_pipeline",
+      "source": "PageRank 1",
+      "sourceHandle": "output",
+      "target": "Database 1",
+      "targetHandle": "data_pipeline"
+    },
+    {
+      "id": "Karate club graph 1 output Common neighbor centrality 1 G",
+      "source": "Karate club graph 1",
+      "sourceHandle": "output",
+      "target": "Common neighbor centrality 1",
+      "targetHandle": "G"
+    },
+    {
+      "id": "Common neighbor centrality 1 output Database 1 data_pipeline",
+      "source": "Common neighbor centrality 1",
+      "sourceHandle": "output",
+      "target": "Database 1",
+      "targetHandle": "data_pipeline"
+    },
+    {
+      "id": "Import file 1 output SQL 1 bundle",
+      "source": "Import file 1",
+      "sourceHandle": "output",
+      "target": "SQL 1",
+      "targetHandle": "bundle"
+    },
+    {
+      "id": "SQL 1 output SQL 2 bundle",
+      "source": "SQL 1",
+      "sourceHandle": "output",
+      "target": "SQL 2",
+      "targetHandle": "bundle"
+    },
+    {
+      "id": "SQL 2 output Database 1 data_pipeline",
+      "source": "SQL 2",
+      "sourceHandle": "output",
+      "target": "Database 1",
+      "targetHandle": "data_pipeline"
+    },
+    {
+      "id": "Agent 2 output Chat frontend 1 agent",
+      "source": "Agent 2",
+      "sourceHandle": "output",
+      "target": "Chat frontend 1",
+      "targetHandle": "agent"
+    },
+    {
+      "id": "MCP: Calculator 1 output Agent 2 tools",
+      "source": "MCP: Calculator 1",
+      "sourceHandle": "output",
+      "target": "Agent 2",
+      "targetHandle": "tools"
+    },
+    {
+      "id": "MCP: Query database with SQL 2 output Agent 2 tools",
+      "source": "MCP: Query database with SQL 2",
+      "sourceHandle": "output",
+      "target": "Agent 2",
+      "targetHandle": "tools"
+    },
+    {
+      "id": "MCP: Financial data 1 output Agent 2 tools",
+      "source": "MCP: Financial data 1",
+      "sourceHandle": "output",
+      "target": "Agent 2",
+      "targetHandle": "tools"
+    },
+    {
+      "id": "MCP: Search web 1 output Agent 2 tools",
+      "source": "MCP: Search web 1",
+      "sourceHandle": "output",
+      "target": "Agent 2",
+      "targetHandle": "tools"
+    }
+  ],
+  "env": "LynxKite Graph Analytics",
+  "nodes": [
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "Data Science"
+          ],
+          "color": "orange",
+          "doc": null,
+          "id": "Data Science > Database",
+          "inputs": [
+            {
+              "name": "data_pipeline",
+              "position": "left",
+              "type": {
+                "type": "list[lynxkite_graph_analytics.core.Bundle]"
+              }
+            }
+          ],
+          "name": "Database",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "Data Science > Database",
+        "params": {},
+        "status": "done",
+        "title": "Database"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "Database 1",
+      "position": {
+        "x": -175.8708861292469,
+        "y": 465.47762360072204
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [
+            "NetworkX",
+            "Generators",
+            "Classic"
+          ],
+          "color": "orange",
+          "doc": null,
+          "id": "NetworkX > Generators > Classic > Ladder graph",
+          "inputs": [],
+          "name": "Ladder graph",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "right",
+              "type": {
+                "type": "<class 'networkx.classes.graph.Graph'>"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": null,
+              "name": "n",
+              "type": {
+                "type": "<class 'int'>"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "NetworkX > Generators > Classic > Ladder graph",
+        "params": {
+          "n": "11"
+        },
+        "status": "done",
+        "title": "Ladder graph"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "Ladder graph 1",
+      "position": {
+        "x": -1297.4471345569843,
+        "y": 364.99969784589774
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "green",
+          "doc": null,
+          "id": "LynxScribe > MCP: Query database with SQL",
+          "inputs": [
+            {
+              "name": "db",
+              "position": "bottom",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            }
+          ],
+          "name": "MCP: Query database with SQL",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > MCP: Query database with SQL",
+        "params": {},
+        "status": "done",
+        "title": "MCP: Query database with SQL"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 152.0,
+      "id": "MCP: Query database with SQL 2",
+      "position": {
+        "x": -248.451978071668,
+        "y": 231.5655840074671
+      },
+      "type": "basic",
+      "width": 334.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "green",
+          "doc": null,
+          "id": "LynxScribe > MCP: Calculator",
+          "inputs": [],
+          "name": "MCP: Calculator",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > MCP: Calculator",
+        "params": {},
+        "status": "done",
+        "title": "MCP: Calculator"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "MCP: Calculator 1",
+      "position": {
+        "x": -527.6679408294542,
+        "y": 240.503939070944
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "collapsed": false,
+        "display": {
+          "dataframes": {
+            "service": {
+              "columns": [
+                "markdown"
+              ],
+              "data": [
+                [
+                  "[Go to frontend](http://localhost:8501/?service=%2Fapi%2Fservice%2Flynxkite_graph_analytics%2FLynxScribe%2FMCP%2FDemo.lynxkite.json%2FChat+frontend+1/chat/completions)"
+                ]
+              ]
+            }
+          }
+        },
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "gray",
+          "doc": null,
+          "id": "LynxScribe > Chat frontend",
+          "inputs": [
+            {
+              "name": "agent",
+              "position": "bottom",
+              "type": {
+                "type": "<class 'dict'>"
+              }
+            }
+          ],
+          "name": "Chat frontend",
+          "outputs": [],
+          "params": [],
+          "type": "service"
+        },
+        "op_id": "LynxScribe > Chat frontend",
+        "params": {},
+        "status": "done",
+        "title": "Chat frontend"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 117.0,
+      "id": "Chat frontend 1",
+      "position": {
+        "x": -1.8364143940130049,
+        "y": -692.5252605263688
+      },
+      "type": "service",
+      "width": 169.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "NetworkX",
+            "Algorithms",
+            "Link analysis",
+            "PageRank alg"
+          ],
+          "color": "orange",
+          "doc": null,
+          "id": "NetworkX > Algorithms > Link analysis > PageRank alg > PageRank",
+          "inputs": [
+            {
+              "name": "G",
+              "position": "left",
+              "type": {
+                "type": "<class 'networkx.classes.graph.Graph'>"
+              }
+            }
+          ],
+          "name": "PageRank",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "right",
+              "type": {
+                "type": "<class 'networkx.classes.graph.Graph'>"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": "0.85",
+              "name": "alpha",
+              "type": {
+                "type": "float | None"
+              }
+            },
+            {
+              "default": "100",
+              "name": "max_iter",
+              "type": {
+                "type": "int | None"
+              }
+            },
+            {
+              "default": "1e-06",
+              "name": "tol",
+              "type": {
+                "type": "float | None"
+              }
+            },
+            {
+              "default": "weight",
+              "name": "weight",
+              "type": {
+                "type": "str | None"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "NetworkX > Algorithms > Link analysis > PageRank alg > PageRank",
+        "params": {
+          "alpha": "0.85",
+          "max_iter": "100",
+          "tol": "1e-06",
+          "weight": "weight"
+        },
+        "status": "done",
+        "title": "PageRank"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "PageRank 1",
+      "position": {
+        "x": -878.5796659405156,
+        "y": 369.96445264090244
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [
+            "NetworkX",
+            "Generators",
+            "Social"
+          ],
+          "color": "orange",
+          "doc": null,
+          "id": "NetworkX > Generators > Social > Karate club graph",
+          "inputs": [],
+          "name": "Karate club graph",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "right",
+              "type": {
+                "type": "<class 'networkx.classes.graph.Graph'>"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "NetworkX > Generators > Social > Karate club graph",
+        "params": {},
+        "status": "done",
+        "title": "Karate club graph"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "Karate club graph 1",
+      "position": {
+        "x": -1304.6391517192224,
+        "y": 585.0242219568652
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "NetworkX",
+            "Algorithms",
+            "Link prediction"
+          ],
+          "color": "orange",
+          "doc": null,
+          "id": "NetworkX > Algorithms > Link prediction > Common neighbor centrality",
+          "inputs": [
+            {
+              "name": "G",
+              "position": "left",
+              "type": {
+                "type": "<class 'networkx.classes.graph.Graph'>"
+              }
+            }
+          ],
+          "name": "Common neighbor centrality",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "right",
+              "type": {
+                "type": "<class 'networkx.classes.graph.Graph'>"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "NetworkX > Algorithms > Link prediction > Common neighbor centrality",
+        "params": {},
+        "status": "done",
+        "title": "Common neighbor centrality"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 130.0,
+      "id": "Common neighbor centrality 1",
+      "position": {
+        "x": -990.2453153930347,
+        "y": 587.3192401780905
+      },
+      "type": "basic",
+      "width": 341.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [],
+          "color": "orange",
+          "doc": [
+            {
+              "kind": "text",
+              "value": "Read the contents of the a file into a `Bundle`."
+            },
+            {
+              "kind": "parameters",
+              "value": [
+                {
+                  "annotation": "str",
+                  "description": "Path to the file to import.",
+                  "name": "file_path"
+                },
+                {
+                  "annotation": "str",
+                  "description": "Name to use for identifying the table in the bundle.",
+                  "name": "table_name"
+                },
+                {
+                  "annotation": "FileFormat",
+                  "description": "Format of the file. Has to be one of the values in the `FileFormat` enum.",
+                  "name": "file_format"
+                }
+              ]
+            },
+            {
+              "kind": "returns",
+              "value": [
+                {
+                  "annotation": "<class 'lynxkite_graph_analytics.core.Bundle'>",
+                  "description": "Bundle with a single table with the contents of the file.",
+                  "name": "Bundle"
+                }
+              ]
+            }
+          ],
+          "id": "Import file",
+          "inputs": [],
+          "name": "Import file",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "right",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": null,
+              "name": "file_path",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            },
+            {
+              "default": null,
+              "name": "table_name",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            },
+            {
+              "default": "csv",
+              "name": "file_format",
+              "type": {
+                "enum": [
+                  "csv",
+                  "parquet",
+                  "json",
+                  "excel"
+                ]
+              }
+            },
+            {
+              "default": "csv",
+              "groups": {
+                "csv": [
+                  {
+                    "default": "<from file>",
+                    "name": "columns",
+                    "type": {
+                      "type": "<class 'str'>"
+                    }
+                  },
+                  {
+                    "default": "<auto>",
+                    "name": "separator",
+                    "type": {
+                      "type": "<class 'str'>"
+                    }
+                  }
+                ],
+                "excel": [
+                  {
+                    "default": "Sheet1",
+                    "name": "sheet_name",
+                    "type": {
+                      "type": "<class 'str'>"
+                    }
+                  }
+                ],
+                "json": [],
+                "parquet": []
+              },
+              "name": "file_format_group",
+              "selector": {
+                "default": "csv",
+                "name": "file_format",
+                "type": {
+                  "enum": [
+                    "csv",
+                    "parquet",
+                    "json",
+                    "excel"
+                  ]
+                }
+              },
+              "type": "group"
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "Import file",
+        "params": {
+          "file_format": "csv",
+          "file_format_group": "csv",
+          "file_path": "uploads/molecules2.csv",
+          "table_name": "molecules"
+        },
+        "status": "done",
+        "title": "Import file"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 393.0,
+      "id": "Import file 1",
+      "position": {
+        "x": -1411.4491034838866,
+        "y": 772.1675932822765
+      },
+      "type": "basic",
+      "width": 369.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {
+            "dataframes": {
+              "molecules": {
+                "columns": [
+                  "name",
+                  "smiles"
+                ],
+                "key": "molecules"
+              }
+            },
+            "other": {},
+            "relations": []
+          }
+        ],
+        "meta": {
+          "categories": [],
+          "color": "orange",
+          "doc": [
+            {
+              "kind": "text",
+              "value": "Run a SQL query on the DataFrames in the bundle. Save the results as a new DataFrame."
+            }
+          ],
+          "id": "SQL",
+          "inputs": [
+            {
+              "name": "bundle",
+              "position": "left",
+              "type": {
+                "type": "<class 'lynxkite_graph_analytics.core.Bundle'>"
+              }
+            }
+          ],
+          "name": "SQL",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "right",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": null,
+              "name": "query",
+              "type": {
+                "format": "textarea"
+              }
+            },
+            {
+              "default": "result",
+              "name": "save_as",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "SQL",
+        "params": {
+          "query": "select *",
+          "save_as": "result"
+        },
+        "status": "done",
+        "title": "SQL"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "SQL 1",
+      "position": {
+        "x": -931.2061769202694,
+        "y": 766.0054007337461
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {
+            "dataframes": {
+              "molecules": {
+                "columns": [
+                  "name",
+                  "smiles"
+                ],
+                "key": "molecules"
+              },
+              "result": {
+                "columns": [],
+                "key": "result"
+              }
+            },
+            "other": {},
+            "relations": []
+          }
+        ],
+        "meta": {
+          "categories": [],
+          "color": "orange",
+          "doc": [
+            {
+              "kind": "text",
+              "value": "Run a SQL query on the DataFrames in the bundle. Save the results as a new DataFrame."
+            }
+          ],
+          "id": "SQL",
+          "inputs": [
+            {
+              "name": "bundle",
+              "position": "left",
+              "type": {
+                "type": "<class 'lynxkite_graph_analytics.core.Bundle'>"
+              }
+            }
+          ],
+          "name": "SQL",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "right",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": null,
+              "name": "query",
+              "type": {
+                "format": "textarea"
+              }
+            },
+            {
+              "default": "result",
+              "name": "save_as",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "SQL",
+        "params": {
+          "query": "select *",
+          "save_as": "result"
+        },
+        "status": "done",
+        "title": "SQL"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "SQL 2",
+      "position": {
+        "x": -633.7783633982368,
+        "y": 767.4541281209835
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "green",
+          "doc": null,
+          "id": "LynxScribe > MCP: Financial data",
+          "inputs": [],
+          "name": "MCP: Financial data",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > MCP: Financial data",
+        "params": {},
+        "status": "done",
+        "title": "MCP: Financial data"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 175.0,
+      "id": "MCP: Financial data 1",
+      "position": {
+        "x": 158.4345441423415,
+        "y": 229.50555825204884
+      },
+      "type": "basic",
+      "width": 242.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "green",
+          "doc": null,
+          "id": "LynxScribe > MCP: Search web",
+          "inputs": [],
+          "name": "MCP: Search web",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": "Google",
+              "name": "engine",
+              "type": {
+                "enum": [
+                  "Google",
+                  "Bing",
+                  "DuckDuckGo"
+                ]
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > MCP: Search web",
+        "params": {
+          "engine": "DuckDuckGo"
+        },
+        "status": "done",
+        "title": "MCP: Search web"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "MCP: Search web 1",
+      "position": {
+        "x": 540.4008718602887,
+        "y": 249.69009586836748
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "blue",
+          "doc": null,
+          "id": "LynxScribe > Agent",
+          "inputs": [
+            {
+              "name": "tools",
+              "position": "bottom",
+              "type": {
+                "type": "list[dict]"
+              }
+            }
+          ],
+          "name": "Agent",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": "",
+              "name": "name",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            },
+            {
+              "default": "This agent helps with various tasks.",
+              "name": "description",
+              "type": {
+                "format": "textarea"
+              }
+            },
+            {
+              "default": "You are a helpful assistant.",
+              "name": "system_prompt",
+              "type": {
+                "format": "textarea"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > Agent",
+        "params": {
+          "description": "",
+          "name": "",
+          "system_prompt": "Using the tools at your disposal answer all questions in an extremely cheerful tone.\nFor queries about movies use the database, not web search.\nFormat the answer as Markdown. Use emojis abundantly."
+        },
+        "status": "done",
+        "title": "Agent"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 438.0,
+      "id": "Agent 2",
+      "position": {
+        "x": -219.84159684352335,
+        "y": -476.0077657450069
+      },
+      "type": "basic",
+      "width": 602.0
+    }
+  ],
+  "paused": false
+}

examples/LynxScribe/MCP/Multi-agent.lynxkite.json

@@ -0,0 +1,599 @@
+{
+  "edges": [
+    {
+      "id": "Database 1 output MCP: Query database with SQL 2 db",
+      "source": "Database 1",
+      "sourceHandle": "output",
+      "target": "MCP: Query database with SQL 2",
+      "targetHandle": "db"
+    },
+    {
+      "id": "Agent 2 output Chat frontend 1 agent",
+      "source": "Agent 2",
+      "sourceHandle": "output",
+      "target": "Chat frontend 1",
+      "targetHandle": "agent"
+    },
+    {
+      "id": "MCP: Calculator 1 output Agent 4 tools",
+      "source": "MCP: Calculator 1",
+      "sourceHandle": "output",
+      "target": "Agent 4",
+      "targetHandle": "tools"
+    },
+    {
+      "id": "MCP: Query database with SQL 2 output Agent 3 tools",
+      "source": "MCP: Query database with SQL 2",
+      "sourceHandle": "output",
+      "target": "Agent 3",
+      "targetHandle": "tools"
+    },
+    {
+      "id": "MCP: Financial data 1 output Agent 3 tools",
+      "source": "MCP: Financial data 1",
+      "sourceHandle": "output",
+      "target": "Agent 3",
+      "targetHandle": "tools"
+    },
+    {
+      "id": "Agent 3 output Agent 2 tools",
+      "source": "Agent 3",
+      "sourceHandle": "output",
+      "target": "Agent 2",
+      "targetHandle": "tools"
+    },
+    {
+      "id": "Agent 4 output Agent 2 tools",
+      "source": "Agent 4",
+      "sourceHandle": "output",
+      "target": "Agent 2",
+      "targetHandle": "tools"
+    },
+    {
+      "id": "MCP: Search web 1 output Agent 2 tools",
+      "source": "MCP: Search web 1",
+      "sourceHandle": "output",
+      "target": "Agent 2",
+      "targetHandle": "tools"
+    }
+  ],
+  "env": "LynxKite Graph Analytics",
+  "nodes": [
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "Data Science"
+          ],
+          "color": "orange",
+          "doc": null,
+          "id": "Data Science > Database",
+          "inputs": [
+            {
+              "name": "data_pipeline",
+              "position": "left",
+              "type": {
+                "type": "list[lynxkite_graph_analytics.core.Bundle]"
+              }
+            }
+          ],
+          "name": "Database",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "Data Science > Database",
+        "params": {},
+        "status": "done",
+        "title": "Database"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "Database 1",
+      "position": {
+        "x": -175.8708861292469,
+        "y": 465.47762360072204
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "green",
+          "doc": null,
+          "id": "LynxScribe > MCP: Query database with SQL",
+          "inputs": [
+            {
+              "name": "db",
+              "position": "bottom",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            }
+          ],
+          "name": "MCP: Query database with SQL",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > MCP: Query database with SQL",
+        "params": {},
+        "status": "done",
+        "title": "MCP: Query database with SQL"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 152.0,
+      "id": "MCP: Query database with SQL 2",
+      "position": {
+        "x": -248.451978071668,
+        "y": 231.5655840074671
+      },
+      "type": "basic",
+      "width": 334.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "green",
+          "doc": null,
+          "id": "LynxScribe > MCP: Calculator",
+          "inputs": [],
+          "name": "MCP: Calculator",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > MCP: Calculator",
+        "params": {},
+        "status": "done",
+        "title": "MCP: Calculator"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "MCP: Calculator 1",
+      "position": {
+        "x": 703.3290222575753,
+        "y": 200.27528014653126
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": {
+          "dataframes": {
+            "service": {
+              "columns": [
+                "url"
+              ],
+              "data": [
+                [
+                  "/api/service/lynxkite_graph_analytics/LynxScribe/MCP/Multi-agent.lynxkite.json/Chat frontend 1"
+                ]
+              ]
+            }
+          }
+        },
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "gray",
+          "doc": null,
+          "id": "LynxScribe > Chat frontend",
+          "inputs": [
+            {
+              "name": "agent",
+              "position": "bottom",
+              "type": {
+                "type": "<class 'dict'>"
+              }
+            }
+          ],
+          "name": "Chat frontend",
+          "outputs": [],
+          "params": [],
+          "type": "service"
+        },
+        "op_id": "LynxScribe > Chat frontend",
+        "params": {},
+        "status": "done",
+        "title": "Chat frontend"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 362.0,
+      "id": "Chat frontend 1",
+      "position": {
+        "x": -146.7467273061735,
+        "y": -1261.9614951572912
+      },
+      "type": "service",
+      "width": 428.0
+    },
+    {
+      "data": {
+        "collapsed": true,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "green",
+          "doc": null,
+          "id": "LynxScribe > MCP: Financial data",
+          "inputs": [],
+          "name": "MCP: Financial data",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > MCP: Financial data",
+        "params": {},
+        "status": "done",
+        "title": "MCP: Financial data"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 175.0,
+      "id": "MCP: Financial data 1",
+      "position": {
+        "x": 158.4345441423415,
+        "y": 229.50555825204884
+      },
+      "type": "basic",
+      "width": 242.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "display": null,
+        "error": null,
+        "input_metadata": [],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "green",
+          "doc": null,
+          "id": "LynxScribe > MCP: Search web",
+          "inputs": [],
+          "name": "MCP: Search web",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": "Google",
+              "name": "engine",
+              "type": {
+                "enum": [
+                  "Google",
+                  "Bing",
+                  "DuckDuckGo"
+                ]
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > MCP: Search web",
+        "params": {
+          "engine": "DuckDuckGo"
+        },
+        "status": "done",
+        "title": "MCP: Search web"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 200.0,
+      "id": "MCP: Search web 1",
+      "position": {
+        "x": -631.594058137602,
+        "y": -415.42373168192296
+      },
+      "type": "basic",
+      "width": 200.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "blue",
+          "doc": null,
+          "id": "LynxScribe > Agent",
+          "inputs": [
+            {
+              "name": "tools",
+              "position": "bottom",
+              "type": {
+                "type": "list[dict]"
+              }
+            }
+          ],
+          "name": "Agent",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": "",
+              "name": "name",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            },
+            {
+              "default": "This agent helps with various tasks.",
+              "name": "description",
+              "type": {
+                "format": "textarea"
+              }
+            },
+            {
+              "default": "You are a helpful assistant.",
+              "name": "system_prompt",
+              "type": {
+                "format": "textarea"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > Agent",
+        "params": {
+          "description": "",
+          "name": "Main conversation",
+          "system_prompt": "Use the agents and tools at your disposal to help the user.\nFormat the answer as Markdown. Make sure no LaTeX fragments remain."
+        },
+        "status": "done",
+        "title": "Agent"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 354.0,
+      "id": "Agent 2",
+      "position": {
+        "x": -207.35812276980303,
+        "y": -1031.390517483489
+      },
+      "type": "basic",
+      "width": 552.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "blue",
+          "doc": null,
+          "id": "LynxScribe > Agent",
+          "inputs": [
+            {
+              "name": "tools",
+              "position": "bottom",
+              "type": {
+                "type": "list[dict]"
+              }
+            }
+          ],
+          "name": "Agent",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": "",
+              "name": "name",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            },
+            {
+              "default": "This agent helps with various tasks.",
+              "name": "description",
+              "type": {
+                "format": "textarea"
+              }
+            },
+            {
+              "default": "You are a helpful assistant.",
+              "name": "system_prompt",
+              "type": {
+                "format": "textarea"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > Agent",
+        "params": {
+          "description": "This agent can help with knowledge tasks regarding movies, actors, and financial stocks.",
+          "name": "Knowledge agent",
+          "system_prompt": "Using the tools at your disposal provide factual answers."
+        },
+        "status": "done",
+        "title": "Agent"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 336.0,
+      "id": "Agent 3",
+      "position": {
+        "x": -194.35714211219977,
+        "y": -436.8444624631063
+      },
+      "type": "basic",
+      "width": 497.0
+    },
+    {
+      "data": {
+        "__execution_delay": 0.0,
+        "display": null,
+        "error": null,
+        "input_metadata": [
+          {}
+        ],
+        "meta": {
+          "categories": [
+            "LynxScribe"
+          ],
+          "color": "blue",
+          "doc": null,
+          "id": "LynxScribe > Agent",
+          "inputs": [
+            {
+              "name": "tools",
+              "position": "bottom",
+              "type": {
+                "type": "list[dict]"
+              }
+            }
+          ],
+          "name": "Agent",
+          "outputs": [
+            {
+              "name": "output",
+              "position": "top",
+              "type": {
+                "type": "None"
+              }
+            }
+          ],
+          "params": [
+            {
+              "default": "",
+              "name": "name",
+              "type": {
+                "type": "<class 'str'>"
+              }
+            },
+            {
+              "default": "This agent helps with various tasks.",
+              "name": "description",
+              "type": {
+                "format": "textarea"
+              }
+            },
+            {
+              "default": "You are a helpful assistant.",
+              "name": "system_prompt",
+              "type": {
+                "format": "textarea"
+              }
+            }
+          ],
+          "type": "basic"
+        },
+        "op_id": "LynxScribe > Agent",
+        "params": {
+          "description": "This agent can help with math problems and logic puzzles.",
+          "name": "Math agent",
+          "system_prompt": "You are a talented mathematician.\nUse the calculator and careful thinking to answer questions.\nAlways check your results and show your work."
+        },
+        "status": "done",
+        "title": "Agent"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 352.0,
+      "id": "Agent 4",
+      "position": {
+        "x": 579.8978751970832,
+        "y": -435.69207900433406
+      },
+      "type": "basic",
+      "width": 444.0
+    }
+  ],
+  "paused": false
+}

examples/LynxScribe/MCP/demo.py

@@ -0,0 +1,26 @@
+from lynxkite_core import ops
+from lynxkite_graph_analytics import core
+
+lsop = ops.op_registration(
+    "LynxKite Graph Analytics", "LynxScribe", dir="bottom-to-top", color="blue"
+)
+dsop = ops.op_registration("LynxKite Graph Analytics", "Data Science")
+
+
+@lsop("MCP: Query database with SQL", color="green")
+def sql_tool(db: str):
+    return {
+        "command": ["npx", "-y", "mcp-sqlite", db],
+        "extra_prompt": """
+When using the database, retrieve the list of tables, investigate the schema of the relevant tables
+and use SQL queries. Always set a limit of 10 when using `read_records`. Unfortunately, `read_records`
+is out of order currently. Please use `query` instead."
+        """.strip(),
+    }
+
+
+@ops.output_position(output="top")
+@dsop("Database")
+def db(data_pipeline: list[core.Bundle]):
+    # The source of this file: https://github.com/biggraph/lynxscribe/pull/416
+    return "movie_data.sqlite.db"

examples/LynxScribe/MCP/demo.sh

@@ -0,0 +1,5 @@
+#!/bin/bash -xue
+xh POST 'http://localhost:8000/api/service/lynxkite_graph_analytics/LynxScribe%20Task%20Solver/Demo.lynxkite.json/Chat%20frontend%201/chat/completions' \
+  model=LynxScribe \
+  stream:=false \
+  messages:='[{"role": "user", "content": "Investigate the database schema, then use a series of SQL queries to find movies featuring Bette Davis and Ann Sheridan together."}]'

examples/LynxScribe/MCP/ui/main.py

@@ -0,0 +1,29 @@
+import streamlit as st
+import requests
+
+node_url = st.query_params["service"]
+api_url = f"http://localhost:8000{node_url}"
+
+st.title("LynxScribe Task Solver")
+
+examples = [
+    "Find the value of x given that 4*x^4 = 44.",
+    "Which movies feature Bette Davis and Ann Sheridan together? Include the year of the movie's release.",
+    "What is the current stock price of Alphabet?",
+    "What is the scientific name of Atlantic cod?",
+]
+selected_example = st.radio("Choose an example:", examples, index=None)
+question = st.text_area(
+    "Your question:", value="" if selected_example is None else selected_example
+)
+if question:
+    payload = {
+        "model": "LynxScribe",
+        "stream": False,
+        "messages": [{"role": "user", "content": question}],
+    }
+    response = requests.post(api_url, json=payload)
+    if response.ok:
+        st.write("\n".join(c["message"]["content"] for c in response.json()["choices"]))
+    else:
+        st.error(f"Error: {response.status_code}")

examples/LynxScribe/MCP/ui/multi_agent.py

@@ -0,0 +1,28 @@
+import streamlit as st
+import requests
+
+API_URL = "http://localhost:8000/api/service/lynxkite_graph_analytics/LynxScribe/MCP/Multi-agent.lynxkite.json/Chat%20frontend%201/chat/completions"
+
+st.title("LynxScribe Multi-Agent Example")
+
+examples = [
+    "Find the value of x given that 4*x^4 = 44.",
+    "Which movies feature Bette Davis and Ann Sheridan together? Include the year of the movie's release.",
+    "What is the current stock price of Alphabet?",
+    "What is the scientific name of Atlantic cod?",
+]
+selected_example = st.radio("Choose an example:", examples, index=None)
+question = st.text_area(
+    "Your question:", value="" if selected_example is None else selected_example
+)
+if question:
+    payload = {
+        "model": "LynxScribe",
+        "stream": False,
+        "messages": [{"role": "user", "content": question}],
+    }
+    response = requests.post(API_URL, json=payload)
+    if response.ok:
+        st.write("\n".join(c["message"]["content"] for c in response.json()["choices"]))
+    else:
+        st.error(f"Error: {response.status_code}")

lynxkite-lynxscribe/src/lynxkite_lynxscribe/__init__.py

@@ -1,3 +1,4 @@
+from . import agentic  # noqa (imported to trigger registration)
 from . import lynxscribe_ops  # noqa (imported to trigger registration)
 from . import llm_ops  # noqa (imported to trigger registration)
 from .lynxscribe_ops import api_service_post, api_service_get

lynxkite-lynxscribe/src/lynxkite_lynxscribe/agentic.py

@@ -0,0 +1,190 @@
+"""Operations that allow LynxScribe agents and MCP servers to be combined with LynxKite pipelines."""
+
+import enum
+import os
+import typing
+
+from lynxkite_core import ops
+from lynxscribe.components.task_solver import TaskSolver
+from lynxscribe.components.mcp import MCPClient
+from lynxscribe.core.llm.base import get_llm_engine
+from lynxscribe.core.models.prompts import Function, Tool
+
+if typing.TYPE_CHECKING:
+    import fastapi
+
+CHAT_FRONTEND_URL = os.environ.get("CHAT_FRONTEND_URL", "http://localhost:8501/")
+
+op = ops.op_registration(
+    "LynxKite Graph Analytics", "LynxScribe", dir="bottom-to-top", color="blue"
+)
+
+
+@op("Chat frontend", color="gray", outputs=[], view="service")
+def chat_frontend(agent: dict):
+    agent = agent["agent"]
+    return Agent(
+        agent["name"],
+        agent["description"],
+        agent["system_prompt"],
+        agent["mcp_servers"],
+        [chat_frontend(a) for a in agent["sub_agents"]],
+    )
+
+
+@op("Agent")
+def agent(
+    tools: list[dict],
+    *,
+    name: str = "",
+    description: ops.LongStr = "This agent helps with various tasks.",
+    system_prompt: ops.LongStr = "You are a helpful assistant.",
+):
+    prompt = [system_prompt]
+    for tool in tools:
+        if tool.get("extra_prompt"):
+            prompt.append(tool["extra_prompt"])
+    return {
+        "agent": {
+            "name": name,
+            "description": description,
+            "system_prompt": "\n".join(prompt),
+            "mcp_servers": [t["command"] for t in tools if "command" in t],
+            "sub_agents": [t for t in tools if "agent" in t],
+        }
+    }
+
+
+@op("MCP: Custom", color="green")
+def custom_mcp(*, command: str, extra_prompt: ops.LongStr):
+    if command.strip():
+        return {"command": command.strip().split(), "extra_prompt": extra_prompt}
+
+
+# A few basic MCP integrations to serve as examples.
+
+
+class MCPSearchEngine(str, enum.Enum):
+    Google = "Google"
+    Bing = "Bing"
+    DuckDuckGo = "DuckDuckGo"
+
+
+@op("MCP: Search web", color="green")
+def web_search(*, engine: MCPSearchEngine = MCPSearchEngine.Google):
+    match engine:
+        case MCPSearchEngine.Google:
+            return {"command": ["npx", "-y", "https://github.com/pskill9/web-search"]}
+        case MCPSearchEngine.Bing:
+            return {"command": ["uvx", "bing-search-mcp"]}
+        case MCPSearchEngine.DuckDuckGo:
+            return {"command": ["uvx", "duckduckgo-mcp-server"]}
+
+
+@op("MCP: Financial data", color="green")
+def financial_data():
+    return {"command": ["uvx", "investor-agent"]}
+
+
+@op("MCP: Calculator", color="green")
+def calculator():
+    return {"command": ["uvx", "mcp-server-calculator"]}
+
+
+@op("MCP: Time", color="green")
+def time():
+    return {"command": ["uvx", "mcp-server-time"]}
+
+
+class Agent:
+    def __init__(
+        self,
+        name: str,
+        description: str,
+        prompt: str,
+        mcp_servers: list[list[str]],
+        agents: list["Agent"],
+    ):
+        self.name = name
+        self.description = description
+        self.prompt = prompt
+        self.mcp_servers = mcp_servers
+        self.agents = agents
+        self.mcp_client = None
+        self.task_solver = None
+
+    async def init(self):
+        if self.task_solver is not None:
+            return
+        self.mcp_client = MCPClient()
+        await self.mcp_client.connect(self.mcp_servers)
+        agents_as_functions = [agent.as_function() for agent in self.agents]
+        self.task_solver = TaskSolver(
+            llm=get_llm_engine(name="openai"),
+            model="gpt-4.1-nano",
+            initial_messages=[self.prompt],
+            functions=[*self.mcp_client.tools, *agents_as_functions],
+            tool_choice="required",
+            temperature=0.0,
+            max_tool_call_steps=999,
+        )
+
+    def get_description(self, url: str) -> str:
+        return f"[Go to frontend]({CHAT_FRONTEND_URL}?service={url}/chat/completions)"
+
+    async def get(self, request: "fastapi.Request") -> dict:
+        if request.state.remaining_path == "models":
+            return {
+                "object": "list",
+                "data": [
+                    {
+                        "id": "LynxScribe",
+                        "object": "model",
+                        "created": 0,
+                        "owned_by": "lynxkite",
+                        "meta": {"profile_image_url": "https://lynxkite.com/favicon.png"},
+                    }
+                ],
+            }
+        return {"error": "Not found"}
+
+    async def post(self, request: "fastapi.Request") -> dict:
+        if request.state.remaining_path == "chat/completions":
+            request = await request.json()
+            assert not request["stream"]
+            await self.init()
+            res = await self.task_solver.solve(request["messages"][-1]["content"])
+            return {"choices": [{"message": {"role": "assistant", "content": res}}]}
+
+        return {"error": "Not found"}
+
+    def as_function(self):
+        """A callable that can be used as a tool by another Agent."""
+
+        # Find the value of x given that 4*x^4 = 44. Compute the numerical value.
+        async def ask(message):
+            print(f"Calling agent {self.name} with message: {message}")
+            await self.init()
+            res = await self.task_solver.solve(message)
+            print(f"Agent {self.name} response: {res}")
+            return res
+
+        ask.__name__ = "ask_" + self.name.lower().replace(" ", "_")
+        ask._tool = Tool(
+            type="function",
+            function=Function(
+                name=ask.__name__,
+                description=self.description,
+                parameters={
+                    "type": "object",
+                    "required": ["message"],
+                    "properties": {
+                        "message": {
+                            "type": "string",
+                            "description": "The question to ask the agent.",
+                        }
+                    },
+                },
+            ),
+        )
+        return ask