Method UnlockJob

database/sql/jobs.go:250–293

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

}

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

	err := s.conn.Transaction(func(tx *gorm.DB) error {
		var workflowJob WorkflowJob
		q := tx.Clauses(clause.Locking{Strength: "UPDATE"}).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 == uuid.Nil {
			// Job is already unlocked.
			return nil
		}

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

		workflowJob.LockedBy = uuid.Nil
		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) CreateOrUpdateJob(ctx context.Context, job params.Job) (params.Job, error) {
	var asParams params.Job