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

Fix schema match (#131)

Browse source
This commit is contained in:
cybermaggedon 2024-10-31 10:10:53 +00:00 • committed by GitHub
parent 24d099793d
commit bc1b38c998
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
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 argparse
import time import time
from .... schema import Triple from .... schema import Triples
from .... schema import triples_store_queue from .... schema import triples_store_queue
from .... base import Consumer from .... base import Consumer
@ -38,7 +38,7 @@ class Processor(Consumer):
**params | { **params | {
"input_queue": input_queue, "input_queue": input_queue,
"subscriber": subscriber, "subscriber": subscriber,
"input_schema": Triple, "input_schema": Triples,
} }
) )
@ -51,7 +51,9 @@ class Processor(Consumer):
def handle(self, msg): def handle(self, msg):
v = msg.value() 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 @staticmethod
def add_args(parser): def add_args(parser):