Class: AWS::SimpleWorkflow::WorkflowExecution

Inherits:
Resource
  • Object
show all
Defined in:
lib/aws/simple_workflow/workflow_execution.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(domain, workflow_id, run_id, options = {}) ⇒ WorkflowExecution 



68
69
70
71
72
73
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 68

def initialize domain, workflow_id, run_id, options = {}
  @domain = domain
  @workflow_id = workflow_id
  @run_id = run_id
  super
end

Instance Attribute Details

#child_policy ⇒ Symbol (readonly)

The policy to use for the child workflow executions if this workflow execution is terminated. The return value will be one of the following values:

  • :terminate - the child executions will be terminated.

  • :request_cancel - a request to cancel will be attempted for each child execution by recording a WorkflowExecutionCancelRequested event in its history. It is up to the decider to take appropriate actions when it receives an execution history with this event.

  • :abandon - no action will be taken. The child executions will continue to run.



66
67
68
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 66

def child_policy
  @child_policy
end

#closed_at ⇒ Time? (readonly)

The time when the workflow execution was closed. Returns nil if this execution is not closed.



66
67
68
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 66

def closed_at
  @closed_at
end

#domain ⇒ Domain (readonly) 



76
77
78
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 76

def domain
  @domain
end

#latest_activity_task_scheduled_at ⇒ Time? (readonly)

The time when the last activity task was scheduled for this workflow execution. You can use this information to determine if the workflow has not made progress for an unusually long period of time and might require a corrective action.



66
67
68
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 66

def latest_activity_task_scheduled_at
  @latest_activity_task_scheduled_at
end

#latest_execution_context ⇒ String? (readonly)

The latest execution context provided by the decider for this workflow execution. A decider can provide an execution context, which is a free form string, when closing a decision task.



66
67
68
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 66

def latest_execution_context
  @latest_execution_context
end

#open_counts ⇒ Hash (readonly)

Returns a hash of counts, including: :open_timers, :open_child_workflow_executions, :open_decision_tasks, and :open_activity_tasks.



66
67
68
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 66

def open_counts
  @open_counts
end

#run_id ⇒ String (readonly) 



82
83
84
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 82

def run_id
  @run_id
end

#start_to_close_timeout ⇒ String (readonly)

The total allowed duration for this workflow execution.

The return value will be formatted as an ISO 8601 duration (e.g. ‘PnYnMnDTnHnMnS’).



66
67
68
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 66

def start_to_close_timeout
  @start_to_close_timeout
end

#started_at ⇒ Time (readonly)

The time when the execution was started.



66
67
68
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 66

def started_at
  @started_at
end

#task_list ⇒ String (readonly)

The task list used for the decision tasks generated for this workflow execution.



66
67
68
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 66

def task_list
  @task_list
end

#task_start_to_close_timeout ⇒ String (readonly)

The maximum duration allowed for decision tasks for this workflow execution.

The return value will be formatted as an ISO 8601 duration (e.g. ‘PnYnMnDTnHnMnS’).



66
67
68
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 66

def task_start_to_close_timeout
  @task_start_to_close_timeout
end

#workflow_id ⇒ String (readonly) 



79
80
81
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 79

def workflow_id
  @workflow_id
end

Instance Method Details

#cancel_requested? ⇒ Boolean 



185
186
187
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 185

def cancel_requested?
  cancel_requested
end

#closed? ⇒ Boolean 



195
196
197
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 195

def closed?
  !open?
end

#count_executions(options = {}) ⇒ Integer

Note:

See AWS::SimpleWorkflow::WorkflowExecutionCollection#count for a broader count.

Note:

This operation is eventually consistent. The results are best effort and may not exactly reflect recent updates and changes.

Counts the number of executions that share the same workflow id.

Options Hash (options):

  • :status (Symbol) — default: :open —

    Specifies that status of the workflow executions to count. Defaults to open workflows.

    • :open

    • :closed

  • :started_between (Array<Time>) —

    A start and end time to filter workflow execution start times by. You may pass an array with two time values or a range. Times should be timestamps (integers), Time, Date, DateTime or parseable time strings.

    You may not pass both :started_between and :closed_between.

  • :closed_between (Array<Time>) —

    A start and end time to filter workflow execution closed times by. You may pass an array with two time values or a range. Times should be timestamps (integers), Time, Date, DateTime or parseable time strings.

    You may not pass both :started_between and :closed_between. You may also not pass :closed_between if the :status is :open.



366
367
368
369
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 366

def count_executions options = {}
  options[:workflow_id] = workflow_id
  domain.workflow_executions.count(options)
end

#history_events ⇒ HistoryEventCollection Also known as: events 



228
229
230
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 228

def history_events
  HistoryEventCollection.new(self)
end

#open? ⇒ Boolean 



190
191
192
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 190

def open?
  status == :open
end

#open_activity_task_count ⇒ Integer 



206
207
208
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 206

def open_activity_task_count
  open_counts[:open_activity_tasks]
end

#open_child_workflow_execution_count ⇒ Boolean 



201
202
203
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 201

def open_child_workflow_execution_count
  open_counts[:open_child_workflow_executions]
end

#open_decision_task_count ⇒ Integer 



216
217
218
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 216

def open_decision_task_count
  open_counts[:open_decision_tasks]
end

#open_timer_count ⇒ Integer 



211
212
213
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 211

def open_timer_count
  open_counts[:open_timers]
end

#parent ⇒ WorkflowExecution? 



241
242
243
244
245
246
247
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 241

def parent
  if parent = self.parent_details
    domain.workflow_executions[parent['workflowId'],parent['runId']]
  else
    nil
  end
end

#request_cancel ⇒ nil

Note:

Because this action allows the workflow to properly clean up and gracefully close, it should be used instead of #terminate when possible.

Records a WorkflowExecutionCancelRequested event in the currently running workflow execution. This logically requests the cancellation of the workflow execution as a whole. It is up to the decider to take appropriate actions when it receives an execution history with this event.



282
283
284
285
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 282

def request_cancel
  options = { :run_id => run_id }
  domain.workflow_executions.request_cancel(workflow_id, options)
end

#signal(signal_name, options = {}) ⇒ nil

Records a WorkflowExecutionSignaled event in the workflow execution history and creates a decision task for the workflow execution.

workflow_execution.signal('signal_name', :input => '...')

Options Hash (options):

  • :input (String) — default: nil —

    Data to attach to the WorkflowExecutionSignaled event in the target workflow execution’s history.



265
266
267
268
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 265

def signal signal_name, options = {}
  options[:run_id] = run_id
  domain.workflow_executions.signal(workflow_id, signal_name, options)
end

#status ⇒ Symbol 



177
178
179
180
181
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 177

def status
  AWS.memoize do
    execution_status == :open ? :open : (close_status || :closed)
  end
end

#tags ⇒ Array<String> 



222
223
224
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 222

def tags
  tag_list || []
end

#terminate(options = {}) ⇒ nil

Note:

If the workflow execution was in progress, it is terminated immediately.

Note:

You should consider canceling the workflow execution instead because it allows the workflow to gracefully close while terminate does not.

Records a WorkflowExecutionTerminated event and forces closure of the workflow execution. The child policy, registered with the workflow type or specified when starting this execution, is applied to any open child workflow executions of this workflow execution.

Options Hash (options):

  • :child_policy (Symbol) — default: nil —

    If set, specifies the policy to use for the child workflow executions of the workflow execution being terminated. This policy overrides the default child policy. Valid policies include:

    • :terminate - the child executions will be terminated.

    • :request_cancel - a request to cancel will be attempted for each child execution by recording a WorkflowExecutionCancelRequested event in its history. It is up to the decider to take appropriate actions when it receives an execution history with this event.

    • :abandon - no action will be taken. The child executions will continue to run.

  • :details (String) — default: nil —

    Optional details for terminating the workflow execution.

  • :reason (String) — default: nil —

    An optional descriptive reason for terminating the workflow execution.



324
325
326
327
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 324

def terminate options = {}
  options[:run_id] = run_id
  domain.workflow_executions.terminate(workflow_id, options)
end

#workflow_type ⇒ WorkflowType 



234
235
236
237
 
# File 'lib/aws/simple_workflow/workflow_execution.rb', line 234

def workflow_type
  type = self.type_details
  WorkflowType.new(domain, type['name'], type['version'])
end