Skip to content

Commit 0487488

Browse files
committed
Fixed failure on parallel ingestion.
1 parent 15697c2 commit 0487488

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

cpp/deeplake_pg/table_storage.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -366,7 +366,7 @@ void table_storage::load_table_metadata()
366366
// This avoids calling the SQL function create_deeplake_table which may not exist
367367
resetStringInfo(&buf);
368368
const char* qtable = quote_identifier(meta.table_name.c_str());
369-
appendStringInfo(&buf, "CREATE TABLE %s.%s (", qschema, qtable);
369+
appendStringInfo(&buf, "CREATE TABLE IF NOT EXISTS %s.%s (", qschema, qtable);
370370

371371
bool first = true;
372372
for (const auto& col : table_columns) {

0 commit comments

Comments
 (0)