|
|
@ -85,7 +85,8 @@ class import_distill_io_json(Importer):
|
|
|
|
now = time.time()
|
|
|
|
now = time.time()
|
|
|
|
self.new_uuids=[]
|
|
|
|
self.new_uuids=[]
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# @todo Use JSONSchema like in the API to validate here.
|
|
|
|
|
|
|
|
|
|
|
|
try:
|
|
|
|
try:
|
|
|
|
data = json.loads(data.strip())
|
|
|
|
data = json.loads(data.strip())
|
|
|
|
except json.decoder.JSONDecodeError:
|
|
|
|
except json.decoder.JSONDecodeError:
|
|
|
@ -120,11 +121,8 @@ class import_distill_io_json(Importer):
|
|
|
|
except IndexError:
|
|
|
|
except IndexError:
|
|
|
|
pass
|
|
|
|
pass
|
|
|
|
|
|
|
|
|
|
|
|
# Does this need to be here anymore?
|
|
|
|
|
|
|
|
if d.get('tags', False):
|
|
|
|
|
|
|
|
extras['tags'] = ", ".join(d['tags'])
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
new_uuid = datastore.add_watch(url=d['uri'].strip(),
|
|
|
|
new_uuid = datastore.add_watch(url=d['uri'].strip(),
|
|
|
|
|
|
|
|
tag=",".join(d.get('tags', [])),
|
|
|
|
extras=extras,
|
|
|
|
extras=extras,
|
|
|
|
write_to_disk_now=False)
|
|
|
|
write_to_disk_now=False)
|
|
|
|
|
|
|
|
|
|
|
|