Module: AcidicJob::Staging

Extended by:
ActiveSupport::Concern
Defined in:
lib/acidic_job/staging.rb

Instance Method Summary collapse

Instance Method Details

#delete_staged_job_record ⇒ Object 



9
10
11
12
13
14
15
16
 
# File 'lib/acidic_job/staging.rb', line 9

def delete_staged_job_record
  return unless was_staged_job?

  staged_job_run.delete
  true
rescue ActiveRecord::RecordNotFound
  true
end

#staged_job_run ⇒ Object 



22
23
24
25
26
27
28
 
# File 'lib/acidic_job/staging.rb', line 22

def staged_job_run
  # "STG_#{idempotency_key}__#{encoded_global_id}"
  encoded_global_id = identifier.split("__").last
  staged_job_gid = "gid://#{Base64.decode64(encoded_global_id)}"

  GlobalID::Locator.locate(staged_job_gid)
end

#was_staged_job? ⇒ Boolean

Returns:

  • (Boolean) 


18
19
20
 
# File 'lib/acidic_job/staging.rb', line 18

def was_staged_job?
  identifier.start_with? "STG_"
end