equal
deleted
inserted
replaced
69 importer.import_entities(set_cwuri(extentities)) |
69 importer.import_entities(set_cwuri(extentities)) |
70 """ |
70 """ |
71 def use_extid_as_cwuri_filter(extentities): |
71 def use_extid_as_cwuri_filter(extentities): |
72 for extentity in extentities: |
72 for extentity in extentities: |
73 if extentity.extid not in extid2eid: |
73 if extentity.extid not in extid2eid: |
74 extentity.values.setdefault('cwuri', set([extentity.extid.decode('utf-8')])) |
74 cwuri = extentity.extid |
|
75 if isinstance(cwuri, bytes): |
|
76 cwuri = cwuri.decode('utf-8') |
|
77 extentity.values.setdefault('cwuri', set([cwuri])) |
75 yield extentity |
78 yield extentity |
76 return use_extid_as_cwuri_filter |
79 return use_extid_as_cwuri_filter |
77 |
80 |
78 |
81 |
79 def drop_extra_values(extentities, schema, import_log): |
82 def drop_extra_values(extentities, schema, import_log): |