PlanOpticon
Merge pull request #49 from ConflictHQ/feat/falkordb-integration feat(graph): FalkorDB integration + query command
Commit
b03c50f147d62797e3d7b5003fdac24b54383593867373a611508dd7474ce68a
Parent
b363c5b9a42791e…
2 files changed
+1
-1
+6
+1
-1
| --- pyproject.toml | ||
| +++ pyproject.toml | ||
| @@ -54,11 +54,11 @@ | ||
| 54 | 54 | [project.optional-dependencies] |
| 55 | 55 | pdf = ["weasyprint>=60.0"] |
| 56 | 56 | gpu = ["torch>=2.0.0", "torchvision>=0.15.0"] |
| 57 | 57 | gdrive = ["google-auth>=2.0.0", "google-auth-oauthlib>=1.0.0", "google-api-python-client>=2.0.0"] |
| 58 | 58 | dropbox = ["dropbox>=12.0.0"] |
| 59 | -graph = ["falkordblite>=0.4.0", "redis>=4.5,<7"] | |
| 59 | +graph = ["falkordblite>=0.4.0", "redis>=4.5"] | |
| 60 | 60 | cloud = [ |
| 61 | 61 | "planopticon[gdrive]", |
| 62 | 62 | "planopticon[dropbox]", |
| 63 | 63 | ] |
| 64 | 64 | dev = [ |
| 65 | 65 |
| --- pyproject.toml | |
| +++ pyproject.toml | |
| @@ -54,11 +54,11 @@ | |
| 54 | [project.optional-dependencies] |
| 55 | pdf = ["weasyprint>=60.0"] |
| 56 | gpu = ["torch>=2.0.0", "torchvision>=0.15.0"] |
| 57 | gdrive = ["google-auth>=2.0.0", "google-auth-oauthlib>=1.0.0", "google-api-python-client>=2.0.0"] |
| 58 | dropbox = ["dropbox>=12.0.0"] |
| 59 | graph = ["falkordblite>=0.4.0", "redis>=4.5,<7"] |
| 60 | cloud = [ |
| 61 | "planopticon[gdrive]", |
| 62 | "planopticon[dropbox]", |
| 63 | ] |
| 64 | dev = [ |
| 65 |
| --- pyproject.toml | |
| +++ pyproject.toml | |
| @@ -54,11 +54,11 @@ | |
| 54 | [project.optional-dependencies] |
| 55 | pdf = ["weasyprint>=60.0"] |
| 56 | gpu = ["torch>=2.0.0", "torchvision>=0.15.0"] |
| 57 | gdrive = ["google-auth>=2.0.0", "google-auth-oauthlib>=1.0.0", "google-api-python-client>=2.0.0"] |
| 58 | dropbox = ["dropbox>=12.0.0"] |
| 59 | graph = ["falkordblite>=0.4.0", "redis>=4.5"] |
| 60 | cloud = [ |
| 61 | "planopticon[gdrive]", |
| 62 | "planopticon[dropbox]", |
| 63 | ] |
| 64 | dev = [ |
| 65 |
| --- video_processor/integrators/graph_store.py | ||
| +++ video_processor/integrators/graph_store.py | ||
| @@ -178,10 +178,16 @@ | ||
| 178 | 178 | |
| 179 | 179 | class FalkorDBStore(GraphStore): |
| 180 | 180 | """FalkorDB Lite-backed graph store. Requires falkordblite package.""" |
| 181 | 181 | |
| 182 | 182 | def __init__(self, db_path: Union[str, Path]) -> None: |
| 183 | + # Patch redis 7.x compat: UnixDomainSocketConnection missing 'port' | |
| 184 | + import redis.connection | |
| 185 | + | |
| 186 | + if not hasattr(redis.connection.UnixDomainSocketConnection, "port"): | |
| 187 | + redis.connection.UnixDomainSocketConnection.port = 0 | |
| 188 | + | |
| 183 | 189 | from redislite import FalkorDB |
| 184 | 190 | |
| 185 | 191 | self._db_path = str(db_path) |
| 186 | 192 | self._db = FalkorDB(self._db_path) |
| 187 | 193 | self._graph = self._db.select_graph("knowledge") |
| 188 | 194 |
| --- video_processor/integrators/graph_store.py | |
| +++ video_processor/integrators/graph_store.py | |
| @@ -178,10 +178,16 @@ | |
| 178 | |
| 179 | class FalkorDBStore(GraphStore): |
| 180 | """FalkorDB Lite-backed graph store. Requires falkordblite package.""" |
| 181 | |
| 182 | def __init__(self, db_path: Union[str, Path]) -> None: |
| 183 | from redislite import FalkorDB |
| 184 | |
| 185 | self._db_path = str(db_path) |
| 186 | self._db = FalkorDB(self._db_path) |
| 187 | self._graph = self._db.select_graph("knowledge") |
| 188 |
| --- video_processor/integrators/graph_store.py | |
| +++ video_processor/integrators/graph_store.py | |
| @@ -178,10 +178,16 @@ | |
| 178 | |
| 179 | class FalkorDBStore(GraphStore): |
| 180 | """FalkorDB Lite-backed graph store. Requires falkordblite package.""" |
| 181 | |
| 182 | def __init__(self, db_path: Union[str, Path]) -> None: |
| 183 | # Patch redis 7.x compat: UnixDomainSocketConnection missing 'port' |
| 184 | import redis.connection |
| 185 | |
| 186 | if not hasattr(redis.connection.UnixDomainSocketConnection, "port"): |
| 187 | redis.connection.UnixDomainSocketConnection.port = 0 |
| 188 | |
| 189 | from redislite import FalkorDB |
| 190 | |
| 191 | self._db_path = str(db_path) |
| 192 | self._db = FalkorDB(self._db_path) |
| 193 | self._graph = self._db.select_graph("knowledge") |
| 194 |