apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-07-16 16:51:02 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

- Fixed schema invocation on Neo4j writer

Browse source 
- Fixed confusing typo name in cassandra template
- Unnecessary import on Cassandra removed
This commit is contained in:
Cyber MacGeddon 2024-11-02 10:47:36 +00:00
parent 614e49997d
commit 555941d861
2 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
trustgraph-flow/trustgraph/storage/triples/cassandra/write.py
View file

@ -10,7 +10,7 @@ import argparse
import time import time
from .... direct.cassandra import TrustGraph from .... direct.cassandra import TrustGraph
from .... schema import Triple, Triples from .... schema import Triples
from .... schema import triples_store_queue from .... schema import triples_store_queue
from .... log_level import LogLevel from .... log_level import LogLevel
from .... base import Consumer from .... base import Consumer

4
trustgraph-flow/trustgraph/storage/triples/neo4j/write.py
View file

@ -11,7 +11,7 @@ import time
from neo4j import GraphDatabase from neo4j import GraphDatabase
from .... schema import Triple from .... schema import Triples
from .... schema import triples_store_queue from .... schema import triples_store_queue
from .... log_level import LogLevel from .... log_level import LogLevel
from .... base import Consumer from .... base import Consumer
@ -39,7 +39,7 @@ class Processor(Consumer):
**params | { **params | {
"input_queue": input_queue, "input_queue": input_queue,
"subscriber": subscriber, "subscriber": subscriber,
"input_schema": Triple, "input_schema": Triples,
"graph_host": graph_host, "graph_host": graph_host,
} }
) )