@@ -80,7 +80,9 @@ class SimpleKGPipelineConfig(TemplatePipelineConfig):
80
80
entities : Sequence [EntityInputType ] = []
81
81
relations : Sequence [RelationInputType ] = []
82
82
potential_schema : Optional [list [tuple [str , str , str ]]] = None
83
- schema_ : Optional [Union [SchemaConfig , dict [str , list [Any ]]]] = Field (default = None , alias = "schema" )
83
+ schema_ : Optional [Union [SchemaConfig , dict [str , list [Any ]]]] = Field (
84
+ default = None , alias = "schema"
85
+ )
84
86
enforce_schema : SchemaEnforcementMode = SchemaEnforcementMode .NONE
85
87
on_error : OnError = OnError .IGNORE
86
88
prompt_template : Union [ERExtractionTemplate , str ] = ERExtractionTemplate ()
@@ -193,14 +195,16 @@ def _process_schema_with_precedence(
193
195
entity_dicts = list (self .schema_ .entities .values ())
194
196
# convert dict values to SchemaEntity objects
195
197
entities = [SchemaEntity .model_validate (e ) for e in entity_dicts ]
196
-
198
+
197
199
# handle case where relations could be None
198
200
if self .schema_ .relations is not None :
199
201
relation_dicts = list (self .schema_ .relations .values ())
200
- relations = [SchemaRelation .model_validate (r ) for r in relation_dicts ]
202
+ relations = [
203
+ SchemaRelation .model_validate (r ) for r in relation_dicts
204
+ ]
201
205
else :
202
206
relations = []
203
-
207
+
204
208
potential_schema = self .schema_ .potential_schema
205
209
else :
206
210
# extract from dictionary
0 commit comments