Sha256: 4b3a88aade1efbc7084d0c28ad94563548ee02ca311ab080bd4caba53d06b134

Contents?: true

Size: 1.45 KB

Versions: 11

Compression:

Stored size: 1.45 KB

Contents

# frozen_string_literal: true

module GoodJob # :nodoc:
  class DiscreteExecution < BaseRecord
    self.table_name = 'good_job_executions'

    belongs_to :execution, class_name: 'GoodJob::Execution', foreign_key: 'active_job_id', primary_key: 'active_job_id', inverse_of: :discrete_executions, optional: true
    belongs_to :job, class_name: 'GoodJob::Job', foreign_key: 'active_job_id', primary_key: 'active_job_id', inverse_of: :discrete_executions, optional: true

    scope :finished, -> { where.not(finished_at: nil) }

    alias_attribute :performed_at, :created_at

    def number
      serialized_params.fetch('executions', 0) + 1
    end

    # Time between when this job was expected to run and when it started running
    def queue_latency
      created_at - scheduled_at
    end

    # Time between when this job started and finished
    def runtime_latency
      (finished_at || Time.current) - performed_at if performed_at
    end

    def last_status_at
      finished_at || created_at
    end

    def status
      if finished_at.present?
        if error.present?
          :retried
        elsif error.present? && job.finished_at.present?
          :discarded
        else
          :succeeded
        end
      else
        :running
      end
    end

    def display_serialized_params
      serialized_params.merge({
                                _good_job_execution: attributes.except('serialized_params'),
                              })
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version Path
good_job-3.15.14 app/models/good_job/discrete_execution.rb
good_job-3.15.13 app/models/good_job/discrete_execution.rb
good_job-3.15.12 app/models/good_job/discrete_execution.rb
good_job-3.15.11 app/models/good_job/discrete_execution.rb
good_job-3.15.10 app/models/good_job/discrete_execution.rb
good_job-3.15.9 app/models/good_job/discrete_execution.rb
good_job-3.15.8 app/models/good_job/discrete_execution.rb
good_job-3.15.7 app/models/good_job/discrete_execution.rb
good_job-3.15.6 app/models/good_job/discrete_execution.rb
good_job-3.15.5 app/models/good_job/discrete_execution.rb
good_job-3.15.4 app/models/good_job/discrete_execution.rb