cmo/triple-tools
1
0
Fork 2
Code Pull requests Packages Activity

fix: Adjust for generator yielding tuples #4

Merged
cmo merged 1 commit from adina/triple-tools:tuples into main 2025-12-19 10:48:11 +00:00
Conversation 1 Commits 1 Files changed 1 +5 -3
1 changed files with 5 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

8
triple_tools/build_local_triple_store.py
View file

@ -44,16 +44,18 @@ def _main():
g = Graph() g = Graph()
for json_object in get_paginated(url_base, page_size=100, token=os.environ.get('DUMPTHINGS_TOKEN')): for json_object in get_paginated(url_base, page_size=100, token=os.environ.get('DUMPTHINGS_TOKEN')):
object_class = json_object.get('schema_type') # the generator yields tuples, thus the index
json_obj = json_object[0]
object_class = json_obj.get('schema_type')
if object_class is None: if object_class is None:
raise ValueError(f'No schema_type in {json_object}') raise ValueError(f'No schema_type in {json_object}')
else: else:
class_name = re.search('([_A-Za-z0-9]*$)', object_class).group(0) class_name = re.search('([_A-Za-z0-9]*$)', object_class).group(0)
try: try:
ttl = converter.convert(json_object, class_name) ttl = converter.convert(json_obj, class_name)
except ValueError as ve: except ValueError as ve:
print(f'WARNING: could not convert record {json_object["pid"]}: {ve}', file=sys.stderr, flush=True) print(f'WARNING: could not convert record {json_obj["pid"]}: {ve}', file=sys.stderr, flush=True)
continue continue
g.parse(io.StringIO(ttl), format='n3') g.parse(io.StringIO(ttl), format='n3')