Basic Cypher box with grand-cypher.

lynxkite-graph-analytics/pyproject.toml

@@ -5,6 +5,7 @@ description = "The graph analytics executor and boxes for LynxKite"
 readme = "README.md"
 requires-python = ">=3.11"
 dependencies = [
+    "grand-cypher>=0.12.0",
     "lynxkite-core",
     "matplotlib>=3.10.0",
     "networkx>=3.4.2",

lynxkite-graph-analytics/src/lynxkite_plugins/graph_analytics/lynxkite_ops.py

@@ -5,6 +5,7 @@ from lynxkite.core import ops
 from collections import deque
 import dataclasses
 import functools
+import grandcypher
 import matplotlib
 import networkx as nx
 import pandas as pd
@@ -224,9 +225,22 @@ def sql(bundle: Bundle, *, query: ops.LongStr, save_as: str = "result"):
     return bundle
 
 
+@op("Cypher")
+def cypher(bundle: Bundle, *, query: ops.LongStr, save_as: str = "result"):
+    """Run a Cypher query on the graph in the bundle. Save the results as a new DataFrame."""
+    bundle = bundle.copy()
+    graph = bundle.to_nx()
+    res = grandcypher.GrandCypher(graph).run(query)
+    bundle.dfs[save_as] = pd.DataFrame(res)
+    return bundle
+
+
 @op("Organize bundle")
 def organize_bundle(bundle: Bundle, *, code: ops.LongStr):
-    """Lets you rename/copy/delete DataFrames, and modify relations. TODO: Use a declarative solution instead of Python code. Add UI."""
+    """Lets you rename/copy/delete DataFrames, and modify relations.
+
+    TODO: Use a declarative solution instead of Python code. Add UI.
+    """
     bundle = bundle.copy()
     exec(code, globals(), {"bundle": bundle})
     return bundle

lynxkite-graph-analytics/uv.lock

@@ -127,6 +127,26 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/99/3b/406d17b1f63e04a82aa621936e6e1c53a8c05458abd66300ac85ea7f9ae9/fonttools-4.55.3-py3-none-any.whl", hash = "sha256:f412604ccbeee81b091b420272841e5ec5ef68967a9790e80bffd0e30b8e2977", size = 1111638 },
 ]
 
+[[package]]
+name = "grand-cypher"
+version = "0.12.0"
+source = { registry = "https://pypi.org/simple" }
+dependencies = [
+    { name = "grandiso" },
+    { name = "lark" },
+    { name = "networkx" },
+]
+sdist = { url = "https://files.pythonhosted.org/packages/af/3e/9548603df25f4f7bc248b898ff49125fde53a0cd627ef993fb083a4cf1be/grand-cypher-0.12.0.tar.gz", hash = "sha256:95664ad6b91926872116c019ae6235306b40a2940ff32e1cb1391dc22c6103c5", size = 24722 }
+
+[[package]]
+name = "grandiso"
+version = "2.2.0"
+source = { registry = "https://pypi.org/simple" }
+dependencies = [
+    { name = "networkx" },
+]
+sdist = { url = "https://files.pythonhosted.org/packages/65/c6/27400e2d81bd769ebe65c695cead44c8efb55ac3769826a01c9223d65709/grandiso-2.2.0.tar.gz", hash = "sha256:66f292d27328e13122065c7905ad0ac79c4649f69a35e7b98a3631654a0bf77c", size = 16277 }
+
 [[package]]
 name = "kiwisolver"
 version = "1.4.8"
@@ -193,6 +213,15 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/4c/fa/be89a49c640930180657482a74970cdcf6f7072c8d2471e1babe17a222dc/kiwisolver-1.4.8-cp313-cp313t-musllinux_1_2_x86_64.whl", hash = "sha256:be4816dc51c8a471749d664161b434912eee82f2ea66bd7628bd14583a833e85", size = 2349213 },
 ]
 
+[[package]]
+name = "lark"
+version = "1.2.2"
+source = { registry = "https://pypi.org/simple" }
+sdist = { url = "https://files.pythonhosted.org/packages/af/60/bc7622aefb2aee1c0b4ba23c1446d3e30225c8770b38d7aedbfb65ca9d5a/lark-1.2.2.tar.gz", hash = "sha256:ca807d0162cd16cef15a8feecb862d7319e7a09bdb13aef927968e45040fed80", size = 252132 }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/2d/00/d90b10b962b4277f5e64a78b6609968859ff86889f5b898c1a778c06ec00/lark-1.2.2-py3-none-any.whl", hash = "sha256:c2276486b02f0f1b90be155f2c8ba4a8e194d42775786db622faccd652d8e80c", size = 111036 },
+]
+
 [[package]]
 name = "libcudf-cu12"
 version = "24.12.0"
@@ -243,6 +272,7 @@ name = "lynxkite-graph-analytics"
 version = "0.1.0"
 source = { virtual = "." }
 dependencies = [
+    { name = "grand-cypher" },
     { name = "lynxkite-core" },
     { name = "matplotlib" },
     { name = "networkx" },
@@ -252,6 +282,7 @@ dependencies = [
 
 [package.metadata]
 requires-dist = [
+    { name = "grand-cypher", specifier = ">=0.12.0" },
     { name = "lynxkite-core", virtual = "../lynxkite-core" },
     { name = "matplotlib", specifier = ">=3.10.0" },
     { name = "networkx", specifier = ">=3.4.2" },