Skip to content

Commit

Permalink
Merge pull request #269 from tigrisdata/main
Browse files Browse the repository at this point in the history
  • Loading branch information
ovaistariq authored May 14, 2023
2 parents a507258 + ae8d3e4 commit 31af4be
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions cmd/import.go
Original file line number Diff line number Diff line change
Expand Up @@ -80,11 +80,6 @@ func evolveSchema(ctx context.Context, db string, coll string, docs []json.RawMe
}

func writeInitRecord(ctx context.Context, coll string, docs []json.RawMessage) {
initDoc, err := schema.GenerateInitDoc(&sch, docs[0])
log.Debug().Interface("initDoc", string(initDoc)).Msg("generating init record")

util.Fatal(err, "init record generation")

if !FirstRecord {
return
}
Expand All @@ -108,6 +103,11 @@ func writeInitRecord(ctx context.Context, coll string, docs []json.RawMessage) {
return
}

initDoc, err := schema.GenerateInitDoc(&sch, docs[0])
log.Debug().Interface("initDoc", string(initDoc)).Msg("generating init record")

util.Fatal(err, "init record generation")

err = client.Transact(ctx, config.GetProjectName(), func(ctx context.Context, tx driver.Tx) error {
_, err = tx.Insert(ctx, coll, []driver.Document{initDoc})
util.Fatal(err, "insert init record")
Expand Down

0 comments on commit 31af4be

Please sign in to comment.