Method BreakLockJobIsQueued

database/sql/jobs.go:209–248

(_ context.Context, jobID int64)

}

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

	err := s.conn.Transaction(func(tx *gorm.DB) error {
		var workflowJob WorkflowJob
		q := tx.Clauses(clause.Locking{Strength: "UPDATE"}).Preload("Instance").Where("workflow_job_id = ? and status = ?", jobID, params.JobStatusQueued).First(&workflowJob)

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

		if workflowJob.LockedBy == uuid.Nil {
			// Job is already unlocked.
			return nil
		}

		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) UnlockJob(_ context.Context, jobID int64, entityID string) error {
	var asParams params.Job