ChatAPI and TaskSolver serving from LynxKite.

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, path: str) -> dict:
+        if 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, path: str) -> dict:
+        if 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 1 output Chat frontend 1 agent",
+      "source": "Agent 1",
+      "sourceHandle": "output",
+      "target": "Chat frontend 1",
+      "targetHandle": "agent"
+    },
+    {
+      "id": "MCP: Financial data 1 output Agent 1 tools",
+      "source": "MCP: Financial data 1",
+      "sourceHandle": "output",
+      "target": "Agent 1",
+      "targetHandle": "tools"
+    },
+    {
+      "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": "MCP: Calculator 1 output Agent 1 tools",
+      "source": "MCP: Calculator 1",
+      "sourceHandle": "output",
+      "target": "Agent 1",
+      "targetHandle": "tools"
+    },
+    {
+      "id": "MCP: Search web 1 output Agent 1 tools",
+      "source": "MCP: Search web 1",
+      "sourceHandle": "output",
+      "target": "Agent 1",
+      "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": "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": "purpose",
+              "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 data science\nand analytics questions.",
+          "purpose": "Data assistant",
+          "system_prompt": "Using the tools at your disposal answer all questions in JSON format. For queries about movies use the database, not web search. Always answer in JSON."
+        },
+        "status": "done",
+        "title": "Agent"
+      },
+      "dragHandle": ".drag-handle",
+      "height": 432.0,
+      "id": "Agent 1",
+      "position": {
+        "x": -162.02870375433838,
+        "y": -454.2852833821508
+      },
+      "type": "basic",
+      "width": 479.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": true,
+        "display": {
+          "dataframes": {
+            "service": {
+              "columns": [
+                "url"
+              ],
+              "data": [
+                [
+                  "/api/service/lynxkite_graph_analytics/LynxScribe Task Solver/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 '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": -138.70099552129096,
+        "y": -642.4401477213354
+      },
+      "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": {
+        "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
+    }
+  ],
+  "paused": false
+}

examples/LynxScribe/MCP/demo.py

@@ -0,0 +1,211 @@
+import enum
+from lynxkite_core import ops
+from lynxkite_graph_analytics import core
+import fastapi
+from lynxscribe.core.llm.base import get_llm_engine
+from lynxscribe.core.models.prompts import ChatCompletionPrompt
+import contextlib
+import mcp
+from mcp.client.stdio import stdio_client
+from lynxscribe.components.task_solver import TaskSolver
+from lynxscribe.core.models.prompts import Function, Tool
+
+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: dict):
+    tools = [tool["command"] for tool in agent["agent"]["tools"] if tool]
+    return ChatAPIService(agent["agent"]["system_prompt"], tools)
+
+
+@lsop("Agent")
+def agent(
+    tools: list[dict],
+    *,
+    purpose: 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": {"system_prompt": "\n".join(prompt), "tools": tools}}
+
+
+@lsop("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}
+
+
+@lsop("MCP: Query database with SQL", color="green")
+def sql_tool(db: Placeholder):
+    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"
+
+
+class MCPSearchEngine(str, enum.Enum):
+    Google = "Google"
+    Bing = "Bing"
+    DuckDuckGo = "DuckDuckGo"
+
+
+@lsop("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"]}
+
+
+@lsop("MCP: Financial data", color="green")
+def financial_data():
+    return {"command": ["uvx", "investor-agent"]}
+
+
+@lsop("MCP: Calculator", color="green")
+def calculator():
+    return {"command": ["uvx", "mcp-server-calculator"]}
+
+
+class ChatAPIService:
+    def __init__(self, prompt: str, tools: list[list[str]]):
+        self.prompt = prompt
+        self.tools = tools
+        self.mcp_client = None
+        self.task_solver = None
+
+    async def init(self):
+        if self.task_solver is not None:
+            return
+        self.mcp_client = MultiMCPClient()
+        await self.mcp_client.connect(self.tools)
+        self.task_solver = TaskSolver(
+            llm=get_llm_engine(name="openai"),
+            model="gpt-4.1-nano",
+            initial_messages=[self.prompt],
+            functions=self.mcp_client.tools,
+            tool_choice="required",
+            temperature=0.0,
+            max_tool_call_steps=999,
+        )
+
+    async def get(self, request: fastapi.Request, path: str) -> dict:
+        if 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, path: str) -> dict:
+        if 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"}
+
+    async def get_chat_api_response(self, request):
+        request = ChatCompletionPrompt(**request)
+        response = await self.chat_api.answer(request, stream=False)
+        return response.model_dump()
+
+
+class MCPClient:
+    def __init__(self):
+        self.session: mcp.ClientSession | None = None
+        self.exit_stack = contextlib.AsyncExitStack()
+
+    async def connect_to_server(self, config):
+        """Connect to an MCP server."""
+        server_params = mcp.StdioServerParameters(**config)
+        stdio_transport = await self.exit_stack.enter_async_context(stdio_client(server_params))
+        self.stdio, self.write = stdio_transport
+        self.session = await self.exit_stack.enter_async_context(
+            mcp.ClientSession(self.stdio, self.write)
+        )
+        await self.session.initialize()
+        self.connected = True
+        response = await self.session.list_tools()
+        self.tools = [self.to_func(tool) for tool in response.tools]
+
+    async def run_tool(self, tool_name: str, tool_args: dict):
+        print(f"Calling tool {tool_name} with args {tool_args}")
+        return await self.session.call_tool(tool_name, tool_args)
+
+    def to_func(self, tool):
+        """Convert a tool to a callable function."""
+
+        async def func(**kwargs):
+            res = await self.run_tool(tool.name, kwargs)
+            return res.content[0].text
+
+        func.__name__ = tool.name
+        func._tool = Tool(
+            type="function",
+            function=Function(
+                name=tool.name,
+                description=tool.description,
+                parameters=tool.inputSchema,
+            ),
+        )
+        return func
+
+    async def cleanup(self):
+        await self.exit_stack.aclose()
+
+
+class MultiMCPClient:
+    """A client that can connect to multiple MCP servers."""
+
+    async def connect(self, servers: list[str]):
+        self.clients = []
+        for server in servers:
+            client = MCPClient()
+            [command, *args] = server
+            await client.connect_to_server({"command": command, "args": args})
+            self.clients.append(client)
+        tools = []
+        for client in self.clients:
+            tools.extend(client.tools)
+        self.tools = tools
+
+    async def cleanup(self):
+        # Reverse cleanup as in https://github.com/microsoft/semantic-kernel/issues/12627.
+        for client in reversed(self.clients):
+            await client.cleanup()

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/requirements.txt

@@ -0,0 +1,3 @@
+mcp
+streamlit
+../../lynxscribe

examples/LynxScribe/MCP/ui/main.py

@@ -0,0 +1,22 @@
+import streamlit as st
+import requests
+
+API_URL = "http://localhost:8000/api/service/lynxkite_graph_analytics/LynxScribe%20Task%20Solver/Demo.lynxkite.json/Chat%20frontend%201/chat/completions"
+
+st.title("LynxScribe Task Solver")
+
+examples = [
+    "Which movies feature Bette Davis and Ann Sheridan together? Include the year of the movie's release.",
+    "Find the value of x given that 4*x^4 = 44.",
+]
+question = st.text_area("Your question:", value=examples[0])
+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}")