Method DeleteJob

database/sql/jobs.go:118–156

(_ context.Context, jobID int64)

}

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

	err := s.conn.Transaction(func(tx *gorm.DB) error {
		var workflowJob WorkflowJob
		q := tx.Where("workflow_job_id = ?", jobID).Preload("Instance").First(&workflowJob)
		if q.Error != nil {
			if errors.Is(q.Error, gorm.ErrRecordNotFound) {
				return nil
			}
			return fmt.Errorf("error fetching job: %w", q.Error)
		}

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

		q = tx.Delete(&workflowJob)
		if q.Error != nil {
			if errors.Is(q.Error, gorm.ErrRecordNotFound) {
				return nil
			}
			return fmt.Errorf("error deleting job: %w", q.Error)
		}
		return nil
	})
	if err != nil {
		return err
	}

	if removedJob.ID != 0 {
		if notifyErr := s.sendNotify(common.JobEntityType, common.DeleteOperation, removedJob); notifyErr != nil {
			slog.With(slog.Any("error", notifyErr)).Error("failed to send notify")
		}
	}
	return nil
}

func (s *sqlDatabase) LockJob(_ context.Context, jobID int64, entityID string) error {
	entityUUID, err := uuid.Parse(entityID)