Skip to content

Commit 2c11692

Browse files
committed
fix build
1 parent 4101e7c commit 2c11692

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

redisgraph_bulk_loader/bulk_update.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -195,7 +195,14 @@ def bulk_update(
195195
updater = BulkUpdate(
196196
graph, max_token_size, separator, no_header, csv, query, variable_name, client
197197
)
198-
updater.validate_query()
198+
199+
if graph in client.keys():
200+
updater.validate_query()
201+
else:
202+
client.execute_command("GRAPH.QUERY", graph, "RETURN 1")
203+
updater.validate_query()
204+
client.execute_command("GRAPH.DELETE", graph)
205+
199206
updater.process_update_csv()
200207

201208
end_time = timer()

0 commit comments

Comments
 (0)