@@ -1451,7 +1451,7 @@ func (s *server) CompleteJob(ctx context.Context, completed *proto.CompletedJob)
14511451hash := hex .EncodeToString (hashBytes [:])
14521452
14531453// nolint:gocritic // Requires reading "system" files
1454- file ,err := s . Database .GetFileByHashAndCreator (dbauthz .AsSystemRestricted (ctx ), database.GetFileByHashAndCreatorParams {Hash :hash ,CreatedBy :uuid .Nil })
1454+ file ,err := tx .GetFileByHashAndCreator (dbauthz .AsSystemRestricted (ctx ), database.GetFileByHashAndCreatorParams {Hash :hash ,CreatedBy :uuid .Nil })
14551455if err == nil {
14561456// This set of modules is already cached, which means we can reuse them
14571457fileID = uuid.NullUUID {
@@ -1462,7 +1462,7 @@ func (s *server) CompleteJob(ctx context.Context, completed *proto.CompletedJob)
14621462return xerrors .Errorf ("check for cached modules: %w" ,err )
14631463}else {
14641464// nolint:gocritic // Requires creating a "system" file
1465- file ,err = s . Database .InsertFile (dbauthz .AsSystemRestricted (ctx ), database.InsertFileParams {
1465+ file ,err = tx .InsertFile (dbauthz .AsSystemRestricted (ctx ), database.InsertFileParams {
14661466ID :uuid .New (),
14671467Hash :hash ,
14681468CreatedBy :uuid .Nil ,
@@ -1480,7 +1480,7 @@ func (s *server) CompleteJob(ctx context.Context, completed *proto.CompletedJob)
14801480}
14811481}
14821482
1483- err = s . Database .InsertTemplateVersionTerraformValuesByJobID (ctx , database.InsertTemplateVersionTerraformValuesByJobIDParams {
1483+ err = tx .InsertTemplateVersionTerraformValuesByJobID (ctx , database.InsertTemplateVersionTerraformValuesByJobIDParams {
14841484JobID :jobID ,
14851485UpdatedAt :now ,
14861486CachedPlan :plan ,