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

Fix schema match

Browse source
This commit is contained in:
Cyber MacGeddon 2024-10-31 10:09:52 +00:00
parent 24d099793d
commit 9d8194abe6
1 changed files with 5 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

8
trustgraph-parquet/trustgraph/dump/triples/parquet/processor.py
View file

@ -9,7 +9,7 @@ import os
import argparse
import time
from .... schema import Triple
from .... schema import Triples
from .... schema import triples_store_queue
from .... base import Consumer
@ -38,7 +38,7 @@ class Processor(Consumer):
**params | {
"input_queue": input_queue,
"subscriber": subscriber,
"input_schema": Triple,
"input_schema": Triples,
}
)
@ -51,7 +51,9 @@ class Processor(Consumer):
def handle(self, msg):
v = msg.value()
self.writer.write(v.s.value, v.p.value, v.o.value)
for t in v.triples:
self.writer.write(t.s.value, t.p.value, t.o.value)
@staticmethod
def add_args(parser):