Skip to content

Commit e95d8fb

Browse files
committed
Remove transaction for archive download
1 parent a989404 commit e95d8fb

File tree

1 file changed

+3
-8
lines changed

1 file changed

+3
-8
lines changed

services/repository/archiver/archiver.go

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -152,12 +152,7 @@ func (aReq *ArchiveRequest) Await(ctx context.Context) (*repo_model.RepoArchiver
152152
}
153153

154154
func doArchive(ctx context.Context, r *ArchiveRequest) (*repo_model.RepoArchiver, error) {
155-
txCtx, committer, err := db.TxContext(ctx)
156-
if err != nil {
157-
return nil, err
158-
}
159-
defer committer.Close()
160-
ctx, _, finished := process.GetManager().AddContext(txCtx, fmt.Sprintf("ArchiveRequest[%d]: %s", r.RepoID, r.GetArchiveName()))
155+
ctx, _, finished := process.GetManager().AddContext(ctx, fmt.Sprintf("ArchiveRequest[%d]: %s", r.RepoID, r.GetArchiveName()))
161156
defer finished()
162157

163158
archiver, err := repo_model.GetRepoArchiver(ctx, r.RepoID, r.Type, r.CommitID)
@@ -192,7 +187,7 @@ func doArchive(ctx context.Context, r *ArchiveRequest) (*repo_model.RepoArchiver
192187
return nil, err
193188
}
194189
}
195-
return archiver, committer.Commit()
190+
return archiver, nil
196191
}
197192

198193
if !errors.Is(err, os.ErrNotExist) {
@@ -261,7 +256,7 @@ func doArchive(ctx context.Context, r *ArchiveRequest) (*repo_model.RepoArchiver
261256
}
262257
}
263258

264-
return archiver, committer.Commit()
259+
return archiver, nil
265260
}
266261

267262
// ArchiveRepository satisfies the ArchiveRequest being passed in. Processing

0 commit comments

Comments
 (0)