diff --git a/ogc/bblocks/transformers/semantic-uplift.py b/ogc/bblocks/transformers/semantic-uplift.py index f3a4511..b38e8da 100644 --- a/ogc/bblocks/transformers/semantic-uplift.py +++ b/ogc/bblocks/transformers/semantic-uplift.py @@ -12,6 +12,7 @@ default_inputs = [ 'application/json', + 'text/csv' ] default_outputs = [ @@ -26,6 +27,11 @@ def __init__(self): def do_transform(self, metadata: TransformMetadata) -> AnyStr | None: uplift_def = load_yaml(content=metadata.transform_content) + if metadata.source_mime_type == 'text/csv': + raise NotImplementedError( + "CSV input detected for semantic-uplift. " + "CSV->RDF uplift is not implemented yet (hook added for #59)." + ) uplifted = json.dumps(ingest_json.uplift_json(json.loads(metadata.input_data), uplift_def)) data_graph = Graph().parse(data=uplifted, format='json-ld') return data_graph.serialize(format=metadata.target_mime_type)