Corrected error where content was being overwritten
This commit is contained in:
parent
bdacd6ae92
commit
19ff5c95b1
1 changed files with 5 additions and 11 deletions
|
@ -175,19 +175,13 @@ async def add_content(table, content, r_filter=None):
|
||||||
try:
|
try:
|
||||||
if r_filter is not None:
|
if r_filter is not None:
|
||||||
cursor = await r.table(table).filter(r_filter).run(conn)
|
cursor = await r.table(table).filter(r_filter).run(conn)
|
||||||
content = await _convert_to_list(cursor)
|
cur_content = await _convert_to_list(cursor)
|
||||||
if len(content) > 0:
|
if len(cur_content) > 0:
|
||||||
await conn.close()
|
await conn.close()
|
||||||
return False
|
return False
|
||||||
else:
|
await r.table(table).insert(content).run(conn)
|
||||||
await r.table(table).insert(content).run(conn)
|
await conn.close()
|
||||||
await conn.close()
|
return True
|
||||||
return True
|
|
||||||
|
|
||||||
else:
|
|
||||||
await r.table(table).insert(content).run(conn)
|
|
||||||
await conn.close()
|
|
||||||
return True
|
|
||||||
except r.ReqlOpFailedError:
|
except r.ReqlOpFailedError:
|
||||||
# This means the table does not exist
|
# This means the table does not exist
|
||||||
await r.create_table(table).run(conn)
|
await r.create_table(table).run(conn)
|
||||||
|
|
Loading…
Reference in a new issue