Method LockJob

database/sql/jobs.go:158–207

(_ context.Context, jobID int64, entityID string)

}

func (s *sqlDatabase) LockJob(_ context.Context, jobID int64, entityID string) error {
	entityUUID, err := uuid.Parse(entityID)
	if err != nil {
		return fmt.Errorf("error parsing entity id: %w", err)
	}

	var asParams params.Job

	err = s.conn.Transaction(func(tx *gorm.DB) error {
		var workflowJob WorkflowJob
		q := tx.Preload("Instance").Where("workflow_job_id = ?", jobID).First(&workflowJob)

		if q.Error != nil {
			if errors.Is(q.Error, gorm.ErrRecordNotFound) {
				return runnerErrors.ErrNotFound
			}
			return fmt.Errorf("error fetching job: %w", q.Error)
		}

		if workflowJob.LockedBy.String() == entityID {
			// Already locked by us.
			return nil
		}

		if workflowJob.LockedBy != uuid.Nil {
			return runnerErrors.NewConflictError("job is locked by another entity %s", workflowJob.LockedBy.String())
		}

		workflowJob.LockedBy = entityUUID

		if err := tx.Save(&workflowJob).Error; err != nil {
			return fmt.Errorf("error saving job: %w", err)
		}

		var err error
		asParams, err = sqlWorkflowJobToParamsJob(workflowJob)
		if err != nil {
			return fmt.Errorf("error converting job: %w", err)
		}
		return nil
	})
	if err != nil {
		return err
	}

	if asParams.ID != 0 {
		s.sendNotify(common.JobEntityType, common.UpdateOperation, asParams)
	}
	return nil
}

func (s *sqlDatabase) BreakLockJobIsQueued(_ context.Context, jobID int64) error {
	var asParams params.Job