diff --git a/platform/csv/csv.go b/platform/csv/csv.go index 530fd10b..0f0d1d79 100644 --- a/platform/csv/csv.go +++ b/platform/csv/csv.go @@ -146,6 +146,7 @@ func JobCommit(ctx context.Context, file_id int32) error { }).One(ctx, txn) */ } + txn.Commit(ctx) return nil } func JobImport(ctx context.Context, file_id int32, type_ enums.FileuploadCsvtype) error {