Class: ActiveJob::Temporal::Workflows::DeadLetterWorkflow

Inherits:
Temporalio::Workflow::Definition
  • Object
show all
Defined in:
lib/activejob/temporal/workflows/dead_letter_workflow.rb

Instance Method Summary collapse

Instance Method Details

#discard(reason = nil) ⇒ Object 



24
25
26
27
28
29
30
 
# File 'lib/activejob/temporal/workflows/dead_letter_workflow.rb', line 24

def discard(reason = nil)
  if @entry
    mark_discarded_entry(reason)
  else
    @pending_action = [:discarded, reason]
  end
end

#execute(entry) ⇒ Object 



32
33
34
35
36
37
 
# File 'lib/activejob/temporal/workflows/dead_letter_workflow.rb', line 32

def execute(entry)
  @entry = deep_stringify(entry)
  apply_pending_action
  wait_until_terminal_or_expired
  @entry
end

#mark_retried(retry_workflow_id) ⇒ Object 



15
16
17
18
19
20
21
 
# File 'lib/activejob/temporal/workflows/dead_letter_workflow.rb', line 15

def mark_retried(retry_workflow_id)
  if @entry
    mark_retried_entry(retry_workflow_id)
  else
    @pending_action = [:retried, retry_workflow_id]
  end
end