You are viewing documentation for version 1 of the AWS SDK for Ruby. Version 2 documentation can be found here.

Class: AWS::SimpleWorkflow::Client

Inherits:
Core::JSONClient show all
Defined in:
lib/aws/simple_workflow/client.rb

Overview

Client class for Amazon Simple Workflow Service (SWF).

Direct Known Subclasses

V20120125

Defined Under Namespace

Classes: V20120125

Constant Summary

API_VERSION = 
'2012-01-25'

Instance Attribute Summary

Attributes inherited from Core::Client

#config

Instance Method Summary collapse

Methods inherited from Core::Client

#initialize, #log_warning, #operations, #with_http_handler, #with_options

Constructor Details

This class inherits a constructor from AWS::Core::Client

Instance Method Details

#count_closed_workflow_executions(options = {}) ⇒ Core::Response

Calls the CountClosedWorkflowExecutions API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain containing the workflow executions to count.
    • :start_time_filter - (Hash) If specified, only workflow executions that meet the start time criteria of the filter are counted. startTimeFilter and closeTimeFilter are mutually exclusive. You must specify one of these in a request but not both.
      • :oldest_date - required - (Integer<)
      • :latest_date - (Integer<)
    • :close_time_filter - (Hash) If specified, only workflow executions that meet the close time criteria of the filter are counted. startTimeFilter and closeTimeFilter are mutually exclusive. You must specify one of these in a request but not both.
      • :oldest_date - required - (Integer<)
      • :latest_date - (Integer<)
    • :execution_filter - (Hash) If specified, only workflow executions matching the WorkflowId in the filter are counted. closeStatusFilter, executionFilter, typeFilter and tagFilter are mutually exclusive. You can specify at most one of these in a request.
      • :workflow_id - required - (String)
    • :type_filter - (Hash) If specified, indicates the type of the workflow executions to be counted. closeStatusFilter, executionFilter, typeFilter and tagFilter are mutually exclusive. You can specify at most one of these in a request.
      • :name - required - (String)
      • :version - (String)
    • :tag_filter - (Hash) If specified, only executions that have a tag that matches the filter are counted. closeStatusFilter, executionFilter, typeFilter and tagFilter are mutually exclusive. You can specify at most one of these in a request.
      • :tag - required - (String)
    • :close_status_filter - (Hash) If specified, only workflow executions that match this close status are counted. This filter has an affect only if executionStatus is specified as CLOSED. closeStatusFilter, executionFilter, typeFilter and tagFilter are mutually exclusive. You can specify at most one of these in a request.
      • :status - required - (String) Valid values include:
        • COMPLETED
        • FAILED
        • CANCELED
        • TERMINATED
        • CONTINUED_AS_NEW
        • TIMED_OUT

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • count - (Integer)
    • truncated - (Boolean)

#count_open_workflow_executions(options = {}) ⇒ Core::Response

Calls the CountOpenWorkflowExecutions API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain containing the workflow executions to count.
    • :start_time_filter - required - (Hash) Specifies the start time criteria that workflow executions must meet in order to be counted.
      • :oldest_date - required - (Integer<)
      • :latest_date - (Integer<)
    • :type_filter - (Hash) Specifies the type of the workflow executions to be counted. executionFilter, typeFilter and tagFilter are mutually exclusive. You can specify at most one of these in a request.
      • :name - required - (String)
      • :version - (String)
    • :tag_filter - (Hash) If specified, only executions that have a tag that matches the filter are counted. executionFilter, typeFilter and tagFilter are mutually exclusive. You can specify at most one of these in a request.
      • :tag - required - (String)
    • :execution_filter - (Hash) If specified, only workflow executions matching the WorkflowId in the filter are counted. executionFilter, typeFilter and tagFilter are mutually exclusive. You can specify at most one of these in a request.
      • :workflow_id - required - (String)

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • count - (Integer)
    • truncated - (Boolean)

#count_pending_activity_tasks(options = {}) ⇒ Core::Response

Calls the CountPendingActivityTasks API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain that contains the task list.
    • :task_list - required - (Hash) The name of the task list.
      • :name - required - (String)

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • count - (Integer)
    • truncated - (Boolean)

#count_pending_decision_tasks(options = {}) ⇒ Core::Response

Calls the CountPendingDecisionTasks API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain that contains the task list.
    • :task_list - required - (Hash) The name of the task list.
      • :name - required - (String)

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • count - (Integer)
    • truncated - (Boolean)

#deprecate_activity_type(options = {}) ⇒ Core::Response

Calls the DeprecateActivityType API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain in which the activity type is registered.
    • :activity_type - required - (Hash) The activity type to deprecate.
      • :name - required - (String)
      • :version - required - (String)

Returns:

#deprecate_domain(options = {}) ⇒ Core::Response

Calls the DeprecateDomain API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :name - required - (String) The name of the domain to deprecate.

Returns:

#deprecate_workflow_type(options = {}) ⇒ Core::Response

Calls the DeprecateWorkflowType API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain in which the workflow type is registered.
    • :workflow_type - required - (Hash) The workflow type to deprecate.
      • :name - required - (String)
      • :version - required - (String)

Returns:

#describe_activity_type(options = {}) ⇒ Core::Response

Calls the DescribeActivityType API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain in which the activity type is registered.
    • :activity_type - required - (Hash) The activity type to get information about. Activity types are identified by the name and version that were supplied when the activity was registered.
      • :name - required - (String)
      • :version - required - (String)

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • typeInfo - (Hash)
      • activityType - (Hash)
        • name - (String)
        • version - (String)
      • status - (String)
      • description - (String)
      • creationDate - (Time)
      • deprecationDate - (Time)
    • configuration - (Hash)
      • defaultTaskStartToCloseTimeout - (String)
      • defaultTaskHeartbeatTimeout - (String)
      • defaultTaskList - (Hash)
        • name - (String)
      • defaultTaskPriority - (String)
      • defaultTaskScheduleToStartTimeout - (String)
      • defaultTaskScheduleToCloseTimeout - (String)

#describe_domain(options = {}) ⇒ Core::Response

Calls the DescribeDomain API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :name - required - (String) The name of the domain to describe.

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • domainInfo - (Hash)
      • name - (String)
      • status - (String)
      • description - (String)
    • configuration - (Hash)
      • workflowExecutionRetentionPeriodInDays - (String)

#describe_workflow_execution(options = {}) ⇒ Core::Response

Calls the DescribeWorkflowExecution API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain containing the workflow execution.
    • :execution - required - (Hash) The workflow execution to describe.
      • :workflow_id - required - (String)
      • :run_id - required - (String)

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • executionInfo - (Hash)
      • execution - (Hash)
        • workflowId - (String)
        • runId - (String)
      • workflowType - (Hash)
        • name - (String)
        • version - (String)
      • startTimestamp - (Time)
      • closeTimestamp - (Time)
      • executionStatus - (String)
      • closeStatus - (String)
      • parent - (Hash)
        • workflowId - (String)
        • runId - (String)
      • tagList - (Array)
      • cancelRequested - (Boolean)
    • executionConfiguration - (Hash)
      • taskStartToCloseTimeout - (String)
      • executionStartToCloseTimeout - (String)
      • taskList - (Hash)
        • name - (String)
      • taskPriority - (String)
      • childPolicy - (String)
    • openCounts - (Hash)
      • openActivityTasks - (Integer)
      • openDecisionTasks - (Integer)
      • openTimers - (Integer)
      • openChildWorkflowExecutions - (Integer)
    • latestActivityTaskTimestamp - (Time)
    • latestExecutionContext - (String)

#describe_workflow_type(options = {}) ⇒ Core::Response

Calls the DescribeWorkflowType API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain in which this workflow type is registered.
    • :workflow_type - required - (Hash) The workflow type to describe.
      • :name - required - (String)
      • :version - required - (String)

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • typeInfo - (Hash)
      • workflowType - (Hash)
        • name - (String)
        • version - (String)
      • status - (String)
      • description - (String)
      • creationDate - (Time)
      • deprecationDate - (Time)
    • configuration - (Hash)
      • defaultTaskStartToCloseTimeout - (String)
      • defaultExecutionStartToCloseTimeout - (String)
      • defaultTaskList - (Hash)
        • name - (String)
      • defaultTaskPriority - (String)
      • defaultChildPolicy - (String)

#get_workflow_execution_history(options = {}) ⇒ Core::Response

Calls the GetWorkflowExecutionHistory API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain containing the workflow execution.
    • :execution - required - (Hash) Specifies the workflow execution for which to return the history.
      • :workflow_id - required - (String)
      • :run_id - required - (String)
    • :next_page_token - (String) If a NextPageToken was returned by a previous call, there are more results available. To retrieve the next page of results, make the call again using the returned token in nextPageToken. Keep all other arguments unchanged. The configured maximumPageSize determines how many results can be returned in a single call.
    • :maximum_page_size - (Integer) The maximum number of results that will be returned per call. nextPageToken can be used to obtain futher pages of results. The default is 100, which is the maximum allowed page size. You can, however, specify a page size smaller than 100. This is an upper limit only; the actual number of results returned per call may be fewer than the specified maximum.
    • :reverse_order - (Boolean) When set to true , returns the events in reverse order. By default the results are returned in ascending order of the eventTimeStamp of the events.

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • events - (Array)
      • eventTimestamp - (Time)
      • eventType - (String)
      • eventId - (Integer)
      • workflowExecutionStartedEventAttributes - (Hash)
        • input - (String)
        • executionStartToCloseTimeout - (String)
        • taskStartToCloseTimeout - (String)
        • childPolicy - (String)
        • taskList - (Hash)
          • name - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • tagList - (Array)
        • taskPriority - (String)
        • continuedExecutionRunId - (String)
        • parentWorkflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • parentInitiatedEventId - (Integer)
      • workflowExecutionCompletedEventAttributes - (Hash)
        • result - (String)
        • decisionTaskCompletedEventId - (Integer)
      • completeWorkflowExecutionFailedEventAttributes - (Hash)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • workflowExecutionFailedEventAttributes - (Hash)
        • reason - (String)
        • details - (String)
        • decisionTaskCompletedEventId - (Integer)
      • failWorkflowExecutionFailedEventAttributes - (Hash)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • workflowExecutionTimedOutEventAttributes - (Hash)
        • timeoutType - (String)
        • childPolicy - (String)
      • workflowExecutionCanceledEventAttributes - (Hash)
        • details - (String)
        • decisionTaskCompletedEventId - (Integer)
      • cancelWorkflowExecutionFailedEventAttributes - (Hash)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • workflowExecutionContinuedAsNewEventAttributes - (Hash)
        • input - (String)
        • decisionTaskCompletedEventId - (Integer)
        • newExecutionRunId - (String)
        • executionStartToCloseTimeout - (String)
        • taskList - (Hash)
          • name - (String)
        • taskPriority - (String)
        • taskStartToCloseTimeout - (String)
        • childPolicy - (String)
        • tagList - (Array)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
      • continueAsNewWorkflowExecutionFailedEventAttributes - (Hash)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • workflowExecutionTerminatedEventAttributes - (Hash)
        • reason - (String)
        • details - (String)
        • childPolicy - (String)
        • cause - (String)
      • workflowExecutionCancelRequestedEventAttributes - (Hash)
        • externalWorkflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • externalInitiatedEventId - (Integer)
        • cause - (String)
      • decisionTaskScheduledEventAttributes - (Hash)
        • taskList - (Hash)
          • name - (String)
        • taskPriority - (String)
        • startToCloseTimeout - (String)
      • decisionTaskStartedEventAttributes - (Hash)
        • identity - (String)
        • scheduledEventId - (Integer)
      • decisionTaskCompletedEventAttributes - (Hash)
        • executionContext - (String)
        • scheduledEventId - (Integer)
        • startedEventId - (Integer)
      • decisionTaskTimedOutEventAttributes - (Hash)
        • timeoutType - (String)
        • scheduledEventId - (Integer)
        • startedEventId - (Integer)
      • activityTaskScheduledEventAttributes - (Hash)
        • activityType - (Hash)
          • name - (String)
          • version - (String)
        • activityId - (String)
        • input - (String)
        • control - (String)
        • scheduleToStartTimeout - (String)
        • scheduleToCloseTimeout - (String)
        • startToCloseTimeout - (String)
        • taskList - (Hash)
          • name - (String)
        • taskPriority - (String)
        • decisionTaskCompletedEventId - (Integer)
        • heartbeatTimeout - (String)
      • activityTaskStartedEventAttributes - (Hash)
        • identity - (String)
        • scheduledEventId - (Integer)
      • activityTaskCompletedEventAttributes - (Hash)
        • result - (String)
        • scheduledEventId - (Integer)
        • startedEventId - (Integer)
      • activityTaskFailedEventAttributes - (Hash)
        • reason - (String)
        • details - (String)
        • scheduledEventId - (Integer)
        • startedEventId - (Integer)
      • activityTaskTimedOutEventAttributes - (Hash)
        • timeoutType - (String)
        • scheduledEventId - (Integer)
        • startedEventId - (Integer)
        • details - (String)
      • activityTaskCanceledEventAttributes - (Hash)
        • details - (String)
        • scheduledEventId - (Integer)
        • startedEventId - (Integer)
        • latestCancelRequestedEventId - (Integer)
      • activityTaskCancelRequestedEventAttributes - (Hash)
        • decisionTaskCompletedEventId - (Integer)
        • activityId - (String)
      • workflowExecutionSignaledEventAttributes - (Hash)
        • signalName - (String)
        • input - (String)
        • externalWorkflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • externalInitiatedEventId - (Integer)
      • markerRecordedEventAttributes - (Hash)
        • markerName - (String)
        • details - (String)
        • decisionTaskCompletedEventId - (Integer)
      • recordMarkerFailedEventAttributes - (Hash)
        • markerName - (String)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • timerStartedEventAttributes - (Hash)
        • timerId - (String)
        • control - (String)
        • startToFireTimeout - (String)
        • decisionTaskCompletedEventId - (Integer)
      • timerFiredEventAttributes - (Hash)
        • timerId - (String)
        • startedEventId - (Integer)
      • timerCanceledEventAttributes - (Hash)
        • timerId - (String)
        • startedEventId - (Integer)
        • decisionTaskCompletedEventId - (Integer)
      • startChildWorkflowExecutionInitiatedEventAttributes - (Hash)
        • workflowId - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • control - (String)
        • input - (String)
        • executionStartToCloseTimeout - (String)
        • taskList - (Hash)
          • name - (String)
        • taskPriority - (String)
        • decisionTaskCompletedEventId - (Integer)
        • childPolicy - (String)
        • taskStartToCloseTimeout - (String)
        • tagList - (Array)
      • childWorkflowExecutionStartedEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • initiatedEventId - (Integer)
      • childWorkflowExecutionCompletedEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • result - (String)
        • initiatedEventId - (Integer)
        • startedEventId - (Integer)
      • childWorkflowExecutionFailedEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • reason - (String)
        • details - (String)
        • initiatedEventId - (Integer)
        • startedEventId - (Integer)
      • childWorkflowExecutionTimedOutEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • timeoutType - (String)
        • initiatedEventId - (Integer)
        • startedEventId - (Integer)
      • childWorkflowExecutionCanceledEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • details - (String)
        • initiatedEventId - (Integer)
        • startedEventId - (Integer)
      • childWorkflowExecutionTerminatedEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • initiatedEventId - (Integer)
        • startedEventId - (Integer)
      • signalExternalWorkflowExecutionInitiatedEventAttributes - (Hash)
        • workflowId - (String)
        • runId - (String)
        • signalName - (String)
        • input - (String)
        • decisionTaskCompletedEventId - (Integer)
        • control - (String)
      • externalWorkflowExecutionSignaledEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • initiatedEventId - (Integer)
      • signalExternalWorkflowExecutionFailedEventAttributes - (Hash)
        • workflowId - (String)
        • runId - (String)
        • cause - (String)
        • initiatedEventId - (Integer)
        • decisionTaskCompletedEventId - (Integer)
        • control - (String)
      • externalWorkflowExecutionCancelRequestedEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • initiatedEventId - (Integer)
      • requestCancelExternalWorkflowExecutionInitiatedEventAttributes - (Hash)
        • workflowId - (String)
        • runId - (String)
        • decisionTaskCompletedEventId - (Integer)
        • control - (String)
      • requestCancelExternalWorkflowExecutionFailedEventAttributes - (Hash)
        • workflowId - (String)
        • runId - (String)
        • cause - (String)
        • initiatedEventId - (Integer)
        • decisionTaskCompletedEventId - (Integer)
        • control - (String)
      • scheduleActivityTaskFailedEventAttributes - (Hash)
        • activityType - (Hash)
          • name - (String)
          • version - (String)
        • activityId - (String)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • requestCancelActivityTaskFailedEventAttributes - (Hash)
        • activityId - (String)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • startTimerFailedEventAttributes - (Hash)
        • timerId - (String)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • cancelTimerFailedEventAttributes - (Hash)
        • timerId - (String)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • startChildWorkflowExecutionFailedEventAttributes - (Hash)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • cause - (String)
        • workflowId - (String)
        • initiatedEventId - (Integer)
        • decisionTaskCompletedEventId - (Integer)
        • control - (String)
    • nextPageToken - (String)

#list_activity_types(options = {}) ⇒ Core::Response

Calls the ListActivityTypes API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain in which the activity types have been registered.
    • :name - (String) If specified, only lists the activity types that have this name.
    • :registration_status - required - (String) Specifies the registration status of the activity types to list. Valid values include:
      • REGISTERED
      • DEPRECATED
    • :next_page_token - (String) If a NextPageToken was returned by a previous call, there are more results available. To retrieve the next page of results, make the call again using the returned token in nextPageToken. Keep all other arguments unchanged. The configured maximumPageSize determines how many results can be returned in a single call.
    • :maximum_page_size - (Integer) The maximum number of results that will be returned per call. nextPageToken can be used to obtain futher pages of results. The default is 100, which is the maximum allowed page size. You can, however, specify a page size smaller than 100. This is an upper limit only; the actual number of results returned per call may be fewer than the specified maximum.
    • :reverse_order - (Boolean) When set to true , returns the results in reverse order. By default, the results are returned in ascending alphabetical order by name of the activity types.

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • typeInfos - (Array)
      • activityType - (Hash)
        • name - (String)
        • version - (String)
      • status - (String)
      • description - (String)
      • creationDate - (Time)
      • deprecationDate - (Time)
    • nextPageToken - (String)

#list_closed_workflow_executions(options = {}) ⇒ Core::Response

Calls the ListClosedWorkflowExecutions API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain that contains the workflow executions to list.
    • :start_time_filter - (Hash) If specified, the workflow executions are included in the returned results based on whether their start times are within the range specified by this filter. Also, if this parameter is specified, the returned results are ordered by their start times. startTimeFilter and closeTimeFilter are mutually exclusive. You must specify one of these in a request but not both.
      • :oldest_date - required - (Integer<)
      • :latest_date - (Integer<)
    • :close_time_filter - (Hash) If specified, the workflow executions are included in the returned results based on whether their close times are within the range specified by this filter. Also, if this parameter is specified, the returned results are ordered by their close times. startTimeFilter and closeTimeFilter are mutually exclusive. You must specify one of these in a request but not both.
      • :oldest_date - required - (Integer<)
      • :latest_date - (Integer<)
    • :execution_filter - (Hash) If specified, only workflow executions matching the workflow id specified in the filter are returned. closeStatusFilter, executionFilter, typeFilter and tagFilter are mutually exclusive. You can specify at most one of these in a request.
      • :workflow_id - required - (String)
    • :close_status_filter - (Hash) If specified, only workflow executions that match this close status are listed. For example, if TERMINATED is specified, then only TERMINATED workflow executions are listed. closeStatusFilter, executionFilter, typeFilter and tagFilter are mutually exclusive. You can specify at most one of these in a request.
      • :status - required - (String) Valid values include:
        • COMPLETED
        • FAILED
        • CANCELED
        • TERMINATED
        • CONTINUED_AS_NEW
        • TIMED_OUT
    • :type_filter - (Hash) If specified, only executions of the type specified in the filter are returned. closeStatusFilter, executionFilter, typeFilter and tagFilter are mutually exclusive. You can specify at most one of these in a request.
      • :name - required - (String)
      • :version - (String)
    • :tag_filter - (Hash) If specified, only executions that have the matching tag are listed. closeStatusFilter, executionFilter, typeFilter and tagFilter are mutually exclusive. You can specify at most one of these in a request.
      • :tag - required - (String)
    • :next_page_token - (String) If a NextPageToken was returned by a previous call, there are more results available. To retrieve the next page of results, make the call again using the returned token in nextPageToken. Keep all other arguments unchanged. The configured maximumPageSize determines how many results can be returned in a single call.
    • :maximum_page_size - (Integer) The maximum number of results that will be returned per call. nextPageToken can be used to obtain futher pages of results. The default is 100, which is the maximum allowed page size. You can, however, specify a page size smaller than 100. This is an upper limit only; the actual number of results returned per call may be fewer than the specified maximum.
    • :reverse_order - (Boolean) When set to true , returns the results in reverse order. By default the results are returned in descending order of the start or the close time of the executions.

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • executionInfos - (Array)
      • execution - (Hash)
        • workflowId - (String)
        • runId - (String)
      • workflowType - (Hash)
        • name - (String)
        • version - (String)
      • startTimestamp - (Time)
      • closeTimestamp - (Time)
      • executionStatus - (String)
      • closeStatus - (String)
      • parent - (Hash)
        • workflowId - (String)
        • runId - (String)
      • tagList - (Array)
      • cancelRequested - (Boolean)
    • nextPageToken - (String)

#list_domains(options = {}) ⇒ Core::Response

Calls the ListDomains API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :next_page_token - (String) If a NextPageToken was returned by a previous call, there are more results available. To retrieve the next page of results, make the call again using the returned token in nextPageToken. Keep all other arguments unchanged. The configured maximumPageSize determines how many results can be returned in a single call.
    • :registration_status - required - (String) Specifies the registration status of the domains to list. Valid values include:
      • REGISTERED
      • DEPRECATED
    • :maximum_page_size - (Integer) The maximum number of results that will be returned per call. nextPageToken can be used to obtain futher pages of results. The default is 100, which is the maximum allowed page size. You can, however, specify a page size smaller than 100. This is an upper limit only; the actual number of results returned per call may be fewer than the specified maximum.
    • :reverse_order - (Boolean) When set to true , returns the results in reverse order. By default, the results are returned in ascending alphabetical order by name of the domains.

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • domainInfos - (Array)
      • name - (String)
      • status - (String)
      • description - (String)
    • nextPageToken - (String)

#list_open_workflow_executions(options = {}) ⇒ Core::Response

Calls the ListOpenWorkflowExecutions API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain that contains the workflow executions to list.
    • :start_time_filter - required - (Hash) Workflow executions are included in the returned results based on whether their start times are within the range specified by this filter.
      • :oldest_date - required - (Integer<)
      • :latest_date - (Integer<)
    • :type_filter - (Hash) If specified, only executions of the type specified in the filter are returned. executionFilter, typeFilter and tagFilter are mutually exclusive. You can specify at most one of these in a request.
      • :name - required - (String)
      • :version - (String)
    • :tag_filter - (Hash) If specified, only executions that have the matching tag are listed. executionFilter, typeFilter and tagFilter are mutually exclusive. You can specify at most one of these in a request.
      • :tag - required - (String)
    • :next_page_token - (String) If a NextPageToken was returned by a previous call, there are more results available. To retrieve the next page of results, make the call again using the returned token in nextPageToken. Keep all other arguments unchanged. The configured maximumPageSize determines how many results can be returned in a single call.
    • :maximum_page_size - (Integer) The maximum number of results that will be returned per call. nextPageToken can be used to obtain futher pages of results. The default is 100, which is the maximum allowed page size. You can, however, specify a page size smaller than 100. This is an upper limit only; the actual number of results returned per call may be fewer than the specified maximum.
    • :reverse_order - (Boolean) When set to true , returns the results in reverse order. By default the results are returned in descending order of the start time of the executions.
    • :execution_filter - (Hash) If specified, only workflow executions matching the workflow id specified in the filter are returned. executionFilter, typeFilter and tagFilter are mutually exclusive. You can specify at most one of these in a request.
      • :workflow_id - required - (String)

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • executionInfos - (Array)
      • execution - (Hash)
        • workflowId - (String)
        • runId - (String)
      • workflowType - (Hash)
        • name - (String)
        • version - (String)
      • startTimestamp - (Time)
      • closeTimestamp - (Time)
      • executionStatus - (String)
      • closeStatus - (String)
      • parent - (Hash)
        • workflowId - (String)
        • runId - (String)
      • tagList - (Array)
      • cancelRequested - (Boolean)
    • nextPageToken - (String)

#list_workflow_types(options = {}) ⇒ Core::Response

Calls the ListWorkflowTypes API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain in which the workflow types have been registered.
    • :name - (String) If specified, lists the workflow type with this name.
    • :registration_status - required - (String) Specifies the registration status of the workflow types to list. Valid values include:
      • REGISTERED
      • DEPRECATED
    • :next_page_token - (String) If a NextPageToken was returned by a previous call, there are more results available. To retrieve the next page of results, make the call again using the returned token in nextPageToken. Keep all other arguments unchanged. The configured maximumPageSize determines how many results can be returned in a single call.
    • :maximum_page_size - (Integer) The maximum number of results that will be returned per call. nextPageToken can be used to obtain futher pages of results. The default is 100, which is the maximum allowed page size. You can, however, specify a page size smaller than 100. This is an upper limit only; the actual number of results returned per call may be fewer than the specified maximum.
    • :reverse_order - (Boolean) When set to true , returns the results in reverse order. By default the results are returned in ascending alphabetical order of the name of the workflow types.

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • typeInfos - (Array)
      • workflowType - (Hash)
        • name - (String)
        • version - (String)
      • status - (String)
      • description - (String)
      • creationDate - (Time)
      • deprecationDate - (Time)
    • nextPageToken - (String)

#poll_for_activity_task(options = {}) ⇒ Core::Response

Calls the PollForActivityTask API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain that contains the task lists being polled.
    • :task_list - required - (Hash) Specifies the task list to poll for activity tasks. The specified string must not start or end with whitespace. It must not contain a : (colon), / (slash), | (vertical bar), or any control characters (\u0000-\u001f | \u007f - \u009f). Also, it must not contain the literal string "arn".
      • :name - required - (String)
    • :identity - (String) Identity of the worker making the request, recorded in the ActivityTaskStarted event in the workflow history. This enables diagnostic tracing when problems arise. The form of this identity is user defined.

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • taskToken - (String)
    • activityId - (String)
    • startedEventId - (Integer)
    • workflowExecution - (Hash)
      • workflowId - (String)
      • runId - (String)
    • activityType - (Hash)
      • name - (String)
      • version - (String)
    • input - (String)

#poll_for_decision_task(options = {}) ⇒ Core::Response

Calls the PollForDecisionTask API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain containing the task lists to poll.
    • :task_list - required - (Hash) Specifies the task list to poll for decision tasks. The specified string must not start or end with whitespace. It must not contain a : (colon), / (slash), | (vertical bar), or any control characters (\u0000-\u001f | \u007f - \u009f). Also, it must not contain the literal string "arn".
      • :name - required - (String)
    • :identity - (String) Identity of the decider making the request, which is recorded in the DecisionTaskStarted event in the workflow history. This enables diagnostic tracing when problems arise. The form of this identity is user defined.
    • :next_page_token - (String) If a NextPageToken was returned by a previous call, there are more results available. To retrieve the next page of results, make the call again using the returned token in nextPageToken. Keep all other arguments unchanged. The configured maximumPageSize determines how many results can be returned in a single call. The nextPageToken returned by this action cannot be used with GetWorkflowExecutionHistory to get the next page. You must call PollForDecisionTask again (with the nextPageToken) to retrieve the next page of history records. Calling PollForDecisionTask with a nextPageToken will not return a new decision task..
    • :maximum_page_size - (Integer) The maximum number of results that will be returned per call. nextPageToken can be used to obtain futher pages of results. The default is 100, which is the maximum allowed page size. You can, however, specify a page size smaller than 100. This is an upper limit only; the actual number of results returned per call may be fewer than the specified maximum.
    • :reverse_order - (Boolean) When set to true , returns the events in reverse order. By default the results are returned in ascending order of the eventTimestamp of the events.

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • taskToken - (String)
    • startedEventId - (Integer)
    • workflowExecution - (Hash)
      • workflowId - (String)
      • runId - (String)
    • workflowType - (Hash)
      • name - (String)
      • version - (String)
    • events - (Array)
      • eventTimestamp - (Time)
      • eventType - (String)
      • eventId - (Integer)
      • workflowExecutionStartedEventAttributes - (Hash)
        • input - (String)
        • executionStartToCloseTimeout - (String)
        • taskStartToCloseTimeout - (String)
        • childPolicy - (String)
        • taskList - (Hash)
          • name - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • tagList - (Array)
        • taskPriority - (String)
        • continuedExecutionRunId - (String)
        • parentWorkflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • parentInitiatedEventId - (Integer)
      • workflowExecutionCompletedEventAttributes - (Hash)
        • result - (String)
        • decisionTaskCompletedEventId - (Integer)
      • completeWorkflowExecutionFailedEventAttributes - (Hash)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • workflowExecutionFailedEventAttributes - (Hash)
        • reason - (String)
        • details - (String)
        • decisionTaskCompletedEventId - (Integer)
      • failWorkflowExecutionFailedEventAttributes - (Hash)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • workflowExecutionTimedOutEventAttributes - (Hash)
        • timeoutType - (String)
        • childPolicy - (String)
      • workflowExecutionCanceledEventAttributes - (Hash)
        • details - (String)
        • decisionTaskCompletedEventId - (Integer)
      • cancelWorkflowExecutionFailedEventAttributes - (Hash)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • workflowExecutionContinuedAsNewEventAttributes - (Hash)
        • input - (String)
        • decisionTaskCompletedEventId - (Integer)
        • newExecutionRunId - (String)
        • executionStartToCloseTimeout - (String)
        • taskList - (Hash)
          • name - (String)
        • taskPriority - (String)
        • taskStartToCloseTimeout - (String)
        • childPolicy - (String)
        • tagList - (Array)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
      • continueAsNewWorkflowExecutionFailedEventAttributes - (Hash)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • workflowExecutionTerminatedEventAttributes - (Hash)
        • reason - (String)
        • details - (String)
        • childPolicy - (String)
        • cause - (String)
      • workflowExecutionCancelRequestedEventAttributes - (Hash)
        • externalWorkflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • externalInitiatedEventId - (Integer)
        • cause - (String)
      • decisionTaskScheduledEventAttributes - (Hash)
        • taskList - (Hash)
          • name - (String)
        • taskPriority - (String)
        • startToCloseTimeout - (String)
      • decisionTaskStartedEventAttributes - (Hash)
        • identity - (String)
        • scheduledEventId - (Integer)
      • decisionTaskCompletedEventAttributes - (Hash)
        • executionContext - (String)
        • scheduledEventId - (Integer)
        • startedEventId - (Integer)
      • decisionTaskTimedOutEventAttributes - (Hash)
        • timeoutType - (String)
        • scheduledEventId - (Integer)
        • startedEventId - (Integer)
      • activityTaskScheduledEventAttributes - (Hash)
        • activityType - (Hash)
          • name - (String)
          • version - (String)
        • activityId - (String)
        • input - (String)
        • control - (String)
        • scheduleToStartTimeout - (String)
        • scheduleToCloseTimeout - (String)
        • startToCloseTimeout - (String)
        • taskList - (Hash)
          • name - (String)
        • taskPriority - (String)
        • decisionTaskCompletedEventId - (Integer)
        • heartbeatTimeout - (String)
      • activityTaskStartedEventAttributes - (Hash)
        • identity - (String)
        • scheduledEventId - (Integer)
      • activityTaskCompletedEventAttributes - (Hash)
        • result - (String)
        • scheduledEventId - (Integer)
        • startedEventId - (Integer)
      • activityTaskFailedEventAttributes - (Hash)
        • reason - (String)
        • details - (String)
        • scheduledEventId - (Integer)
        • startedEventId - (Integer)
      • activityTaskTimedOutEventAttributes - (Hash)
        • timeoutType - (String)
        • scheduledEventId - (Integer)
        • startedEventId - (Integer)
        • details - (String)
      • activityTaskCanceledEventAttributes - (Hash)
        • details - (String)
        • scheduledEventId - (Integer)
        • startedEventId - (Integer)
        • latestCancelRequestedEventId - (Integer)
      • activityTaskCancelRequestedEventAttributes - (Hash)
        • decisionTaskCompletedEventId - (Integer)
        • activityId - (String)
      • workflowExecutionSignaledEventAttributes - (Hash)
        • signalName - (String)
        • input - (String)
        • externalWorkflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • externalInitiatedEventId - (Integer)
      • markerRecordedEventAttributes - (Hash)
        • markerName - (String)
        • details - (String)
        • decisionTaskCompletedEventId - (Integer)
      • recordMarkerFailedEventAttributes - (Hash)
        • markerName - (String)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • timerStartedEventAttributes - (Hash)
        • timerId - (String)
        • control - (String)
        • startToFireTimeout - (String)
        • decisionTaskCompletedEventId - (Integer)
      • timerFiredEventAttributes - (Hash)
        • timerId - (String)
        • startedEventId - (Integer)
      • timerCanceledEventAttributes - (Hash)
        • timerId - (String)
        • startedEventId - (Integer)
        • decisionTaskCompletedEventId - (Integer)
      • startChildWorkflowExecutionInitiatedEventAttributes - (Hash)
        • workflowId - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • control - (String)
        • input - (String)
        • executionStartToCloseTimeout - (String)
        • taskList - (Hash)
          • name - (String)
        • taskPriority - (String)
        • decisionTaskCompletedEventId - (Integer)
        • childPolicy - (String)
        • taskStartToCloseTimeout - (String)
        • tagList - (Array)
      • childWorkflowExecutionStartedEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • initiatedEventId - (Integer)
      • childWorkflowExecutionCompletedEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • result - (String)
        • initiatedEventId - (Integer)
        • startedEventId - (Integer)
      • childWorkflowExecutionFailedEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • reason - (String)
        • details - (String)
        • initiatedEventId - (Integer)
        • startedEventId - (Integer)
      • childWorkflowExecutionTimedOutEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • timeoutType - (String)
        • initiatedEventId - (Integer)
        • startedEventId - (Integer)
      • childWorkflowExecutionCanceledEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • details - (String)
        • initiatedEventId - (Integer)
        • startedEventId - (Integer)
      • childWorkflowExecutionTerminatedEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • initiatedEventId - (Integer)
        • startedEventId - (Integer)
      • signalExternalWorkflowExecutionInitiatedEventAttributes - (Hash)
        • workflowId - (String)
        • runId - (String)
        • signalName - (String)
        • input - (String)
        • decisionTaskCompletedEventId - (Integer)
        • control - (String)
      • externalWorkflowExecutionSignaledEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • initiatedEventId - (Integer)
      • signalExternalWorkflowExecutionFailedEventAttributes - (Hash)
        • workflowId - (String)
        • runId - (String)
        • cause - (String)
        • initiatedEventId - (Integer)
        • decisionTaskCompletedEventId - (Integer)
        • control - (String)
      • externalWorkflowExecutionCancelRequestedEventAttributes - (Hash)
        • workflowExecution - (Hash)
          • workflowId - (String)
          • runId - (String)
        • initiatedEventId - (Integer)
      • requestCancelExternalWorkflowExecutionInitiatedEventAttributes - (Hash)
        • workflowId - (String)
        • runId - (String)
        • decisionTaskCompletedEventId - (Integer)
        • control - (String)
      • requestCancelExternalWorkflowExecutionFailedEventAttributes - (Hash)
        • workflowId - (String)
        • runId - (String)
        • cause - (String)
        • initiatedEventId - (Integer)
        • decisionTaskCompletedEventId - (Integer)
        • control - (String)
      • scheduleActivityTaskFailedEventAttributes - (Hash)
        • activityType - (Hash)
          • name - (String)
          • version - (String)
        • activityId - (String)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • requestCancelActivityTaskFailedEventAttributes - (Hash)
        • activityId - (String)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • startTimerFailedEventAttributes - (Hash)
        • timerId - (String)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • cancelTimerFailedEventAttributes - (Hash)
        • timerId - (String)
        • cause - (String)
        • decisionTaskCompletedEventId - (Integer)
      • startChildWorkflowExecutionFailedEventAttributes - (Hash)
        • workflowType - (Hash)
          • name - (String)
          • version - (String)
        • cause - (String)
        • workflowId - (String)
        • initiatedEventId - (Integer)
        • decisionTaskCompletedEventId - (Integer)
        • control - (String)
    • nextPageToken - (String)
    • previousStartedEventId - (Integer)

#record_activity_task_heartbeat(options = {}) ⇒ Core::Response

Calls the RecordActivityTaskHeartbeat API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :task_token - required - (String) The taskToken of the ActivityTask. taskToken is generated by the service and should be treated as an opaque value. If the task is passed to another process, its taskToken must also be passed. This enables it to provide its progress and respond with results.
    • :details - (String) If specified, contains details about the progress of the task.

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • cancelRequested - (Boolean)

#register_activity_type(options = {}) ⇒ Core::Response

Calls the RegisterActivityType API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain in which this activity is to be registered.
    • :name - required - (String) The name of the activity type within the domain. The specified string must not start or end with whitespace. It must not contain a : (colon), / (slash), | (vertical bar), or any control characters (\u0000-\u001f | \u007f - \u009f). Also, it must not contain the literal string "arn".
    • :version - required - (String) The version of the activity type. The activity type consists of the name and version, the combination of which must be unique within the domain. The specified string must not start or end with whitespace. It must not contain a : (colon), / (slash), | (vertical bar), or any control characters (\u0000-\u001f | \u007f - \u009f). Also, it must not contain the literal string "arn".
    • :description - (String) A textual description of the activity type.
    • :default_task_start_to_close_timeout - (String) If set, specifies the default maximum duration that a worker can take to process tasks of this activity type. This default can be overridden when scheduling an activity task using the ScheduleActivityTask Decision. The duration is specified in seconds; an integer greater than or equal to 0. The value "NONE" can be used to specify unlimited duration.
    • :default_task_heartbeat_timeout - (String) If set, specifies the default maximum time before which a worker processing a task of this type must report progress by calling RecordActivityTaskHeartbeat. If the timeout is exceeded, the activity task is automatically timed out. This default can be overridden when scheduling an activity task using the ScheduleActivityTask Decision. If the activity worker subsequently attempts to record a heartbeat or returns a result, the activity worker receives an UnknownResource fault. In this case, Amazon SWF no longer considers the activity task to be valid; the activity worker should clean up the activity task. The duration is specified in seconds; an integer greater than or equal to 0. The value "NONE" can be used to specify unlimited duration.
    • :default_task_list - (Hash) If set, specifies the default task list to use for scheduling tasks of this activity type. This default task list is used if a task list is not provided when a task is scheduled through the ScheduleActivityTask Decision.
      • :name - required - (String)
    • :default_task_priority - (String) The default task priority to assign to the activity type. If not assigned, then "0" will be used. Valid values are integers that range from Java's Integer.MIN_VALUE (-2147483648) to Integer.MAX_VALUE (2147483647). Higher numbers indicate higher priority. For more information about setting task priority, see Setting Task Priority in the Amazon Simple Workflow Developer Guide.
    • :default_task_schedule_to_start_timeout - (String) If set, specifies the default maximum duration that a task of this activity type can wait before being assigned to a worker. This default can be overridden when scheduling an activity task using the ScheduleActivityTask Decision. The duration is specified in seconds; an integer greater than or equal to 0. The value "NONE" can be used to specify unlimited duration.
    • :default_task_schedule_to_close_timeout - (String) If set, specifies the default maximum duration for a task of this activity type. This default can be overridden when scheduling an activity task using the ScheduleActivityTask Decision. The duration is specified in seconds; an integer greater than or equal to 0. The value "NONE" can be used to specify unlimited duration.

Returns:

#register_domain(options = {}) ⇒ Core::Response

Calls the RegisterDomain API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :name - required - (String) Name of the domain to register. The name must be unique in the region that the domain is registered in. The specified string must not start or end with whitespace. It must not contain a : (colon), / (slash), | (vertical bar), or any control characters (\u0000-\u001f | \u007f - \u009f). Also, it must not contain the literal string "arn".
    • :description - (String) A text description of the domain.
    • :workflow_execution_retention_period_in_days - required - (String) The duration (in days) that records and histories of workflow executions on the domain should be kept by the service. After the retention period, the workflow execution is not available in the results of visibility calls. If you pass the value NONE or 0 (zero), then the workflow execution history will not be retained. As soon as the workflow execution completes, the execution record and its history are deleted. The maximum workflow execution retention period is 90 days. For more information about Amazon SWF service limits, see: Amazon SWF Service Limits in the Amazon SWF Developer Guide.

Returns:

#register_workflow_type(options = {}) ⇒ Core::Response

Calls the RegisterWorkflowType API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain in which to register the workflow type.
    • :name - required - (String) The name of the workflow type. The specified string must not start or end with whitespace. It must not contain a : (colon), / (slash), | (vertical bar), or any control characters (\u0000-\u001f | \u007f - \u009f). Also, it must not contain the literal string "arn".
    • :version - required - (String) The version of the workflow type. The workflow type consists of the name and version, the combination of which must be unique within the domain. To get a list of all currently registered workflow types, use the ListWorkflowTypes action. The specified string must not start or end with whitespace. It must not contain a : (colon), / (slash), | (vertical bar), or any control characters (\u0000-\u001f | \u007f - \u009f). Also, it must not contain the literal string "arn".
    • :description - (String) Textual description of the workflow type.
    • :default_task_start_to_close_timeout - (String) If set, specifies the default maximum duration of decision tasks for this workflow type. This default can be overridden when starting a workflow execution using the StartWorkflowExecution action or the StartChildWorkflowExecution Decision. The duration is specified in seconds; an integer greater than or equal to 0. The value "NONE" can be used to specify unlimited duration.
    • :default_execution_start_to_close_timeout - (String) If set, specifies the default maximum duration for executions of this workflow type. You can override this default when starting an execution through the StartWorkflowExecution Action or StartChildWorkflowExecution Decision. The duration is specified in seconds; an integer greater than or equal to 0. Unlike some of the other timeout parameters in Amazon SWF, you cannot specify a value of "NONE" for defaultExecutionStartToCloseTimeout; there is a one-year max limit on the time that a workflow execution can run. Exceeding this limit will always cause the workflow execution to time out.
    • :default_task_list - (Hash) If set, specifies the default task list to use for scheduling decision tasks for executions of this workflow type. This default is used only if a task list is not provided when starting the execution through the StartWorkflowExecution Action or StartChildWorkflowExecution Decision.
      • :name - required - (String)
    • :default_task_priority - (String) The default task priority to assign to the workflow type. If not assigned, then "0" will be used. Valid values are integers that range from Java's Integer.MIN_VALUE (-2147483648) to Integer.MAX_VALUE (2147483647). Higher numbers indicate higher priority. For more information about setting task priority, see Setting Task Priority in the Amazon Simple Workflow Developer Guide.
    • :default_child_policy - (String) If set, specifies the default policy to use for the child workflow executions when a workflow execution of this type is terminated, by calling the TerminateWorkflowExecution action explicitly or due to an expired timeout. This default can be overridden when starting a workflow execution using the StartWorkflowExecution action or the StartChildWorkflowExecution Decision. The supported child policies are: 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. Valid values include:
      • TERMINATE
      • REQUEST_CANCEL
      • ABANDON

Returns:

#request_cancel_workflow_execution(options = {}) ⇒ Core::Response

Calls the RequestCancelWorkflowExecution API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain containing the workflow execution to cancel.
    • :workflow_id - required - (String) The workflowId of the workflow execution to cancel.
    • :run_id - (String) The runId of the workflow execution to cancel.

Returns:

#respond_activity_task_canceled(options = {}) ⇒ Core::Response

Calls the RespondActivityTaskCanceled API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :task_token - required - (String) The taskToken of the ActivityTask. taskToken is generated by the service and should be treated as an opaque value. If the task is passed to another process, its taskToken must also be passed. This enables it to provide its progress and respond with results.
    • :details - (String) Optional. Information about the cancellation.

Returns:

#respond_activity_task_completed(options = {}) ⇒ Core::Response

Calls the RespondActivityTaskCompleted API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :task_token - required - (String) The taskToken of the ActivityTask. taskToken is generated by the service and should be treated as an opaque value. If the task is passed to another process, its taskToken must also be passed. This enables it to provide its progress and respond with results.
    • :result - (String) The result of the activity task. It is a free form string that is implementation specific.

Returns:

#respond_activity_task_failed(options = {}) ⇒ Core::Response

Calls the RespondActivityTaskFailed API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :task_token - required - (String) The taskToken of the ActivityTask. taskToken is generated by the service and should be treated as an opaque value. If the task is passed to another process, its taskToken must also be passed. This enables it to provide its progress and respond with results.
    • :reason - (String) Description of the error that may assist in diagnostics.
    • :details - (String) Optional. Detailed information about the failure.

Returns:

#respond_decision_task_completed(options = {}) ⇒ Core::Response

Calls the RespondDecisionTaskCompleted API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :task_token - required - (String) The taskToken from the DecisionTask. taskToken is generated by the service and should be treated as an opaque value. If the task is passed to another process, its taskToken must also be passed. This enables it to provide its progress and respond with results.
    • :decisions - (Array<) The list of decisions (possibly empty) made by the decider while processing this decision task. See the docs for the Decision structure for details.
      • :decision_type - required - (String) Valid values include:
        • ScheduleActivityTask
        • RequestCancelActivityTask
        • CompleteWorkflowExecution
        • FailWorkflowExecution
        • CancelWorkflowExecution
        • ContinueAsNewWorkflowExecution
        • RecordMarker
        • StartTimer
        • CancelTimer
        • SignalExternalWorkflowExecution
        • RequestCancelExternalWorkflowExecution
        • StartChildWorkflowExecution
      • :schedule_activity_task_decision_attributes - (Hash)
        • :activity_type - required - (Hash)
          • :name - required - (String)
          • :version - required - (String)
        • :activity_id - required - (String)
        • :control - (String)
        • :input - (String)
        • :schedule_to_close_timeout - (String)
        • :task_list - (Hash)
          • :name - required - (String)
        • :task_priority - (String)
        • :schedule_to_start_timeout - (String)
        • :start_to_close_timeout - (String)
        • :heartbeat_timeout - (String)
      • :request_cancel_activity_task_decision_attributes - (Hash)
        • :activity_id - required - (String)
      • :complete_workflow_execution_decision_attributes - (Hash)
        • :result - (String)
      • :fail_workflow_execution_decision_attributes - (Hash)
        • :reason - (String)
        • :details - (String)
      • :cancel_workflow_execution_decision_attributes - (Hash)
        • :details - (String)
      • :continue_as_new_workflow_execution_decision_attributes - (Hash)
        • :input - (String)
        • :execution_start_to_close_timeout - (String)
        • :task_list - (Hash)
          • :name - required - (String)
        • :task_priority - (String)
        • :task_start_to_close_timeout - (String)
        • :child_policy - (String) Valid values include:
          • TERMINATE
          • REQUEST_CANCEL
          • ABANDON
        • :tag_list - (Array<)
        • :workflow_type_version - (String)
      • :record_marker_decision_attributes - (Hash)
        • :marker_name - required - (String)
        • :details - (String)
      • :start_timer_decision_attributes - (Hash)
        • :timer_id - required - (String)
        • :control - (String)
        • :start_to_fire_timeout - required - (String)
      • :cancel_timer_decision_attributes - (Hash)
        • :timer_id - required - (String)
      • :signal_external_workflow_execution_decision_attributes - (Hash)
        • :workflow_id - required - (String)
        • :run_id - (String)
        • :signal_name - required - (String)
        • :input - (String)
        • :control - (String)
      • :request_cancel_external_workflow_execution_decision_attributes - (Hash)
        • :workflow_id - required - (String)
        • :run_id - (String)
        • :control - (String)
      • :start_child_workflow_execution_decision_attributes - (Hash)
        • :workflow_type - required - (Hash)
          • :name - required - (String)
          • :version - required - (String)
        • :workflow_id - required - (String)
        • :control - (String)
        • :input - (String)
        • :execution_start_to_close_timeout - (String)
        • :task_list - (Hash)
          • :name - required - (String)
        • :task_priority - (String)
        • :task_start_to_close_timeout - (String)
        • :child_policy - (String) Valid values include:
          • TERMINATE
          • REQUEST_CANCEL
          • ABANDON
        • :tag_list - (Array<)
    • :execution_context - (String) User defined context to add to workflow execution.

Returns:

#signal_workflow_execution(options = {}) ⇒ Core::Response

Calls the SignalWorkflowExecution API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain containing the workflow execution to signal.
    • :workflow_id - required - (String) The workflowId of the workflow execution to signal.
    • :run_id - (String) The runId of the workflow execution to signal.
    • :signal_name - required - (String) The name of the signal. This name must be meaningful to the target workflow.
    • :input - (String) Data to attach to the WorkflowExecutionSignaled event in the target workflow execution's history.

Returns:

#start_workflow_execution(options = {}) ⇒ Core::Response

Calls the StartWorkflowExecution API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The name of the domain in which the workflow execution is created.
    • :workflow_id - required - (String) The user defined identifier associated with the workflow execution. You can use this to associate a custom identifier with the workflow execution. You may specify the same identifier if a workflow execution is logically a restart of a previous execution. You cannot have two open workflow executions with the same workflowId at the same time. The specified string must not start or end with whitespace. It must not contain a : (colon), / (slash), | (vertical bar), or any control characters (\u0000-\u001f | \u007f - \u009f). Also, it must not contain the literal string "arn".
    • :workflow_type - required - (Hash) The type of the workflow to start.
      • :name - required - (String)
      • :version - required - (String)
    • :task_list - (Hash) The task list to use for the decision tasks generated for this workflow execution. This overrides the defaultTaskList specified when registering the workflow type. A task list for this workflow execution must be specified either as a default for the workflow type or through this parameter. If neither this parameter is set nor a default task list was specified at registration time then a fault will be returned. The specified string must not start or end with whitespace. It must not contain a : (colon), / (slash), | (vertical bar), or any control characters (\u0000-\u001f | \u007f - \u009f). Also, it must not contain the literal string "arn".
      • :name - required - (String)
    • :task_priority - (String) The task priority to use for this workflow execution. This will override any default priority that was assigned when the workflow type was registered. If not set, then the default task priority for the workflow type will be used. Valid values are integers that range from Java's Integer.MIN_VALUE (-2147483648) to Integer.MAX_VALUE (2147483647). Higher numbers indicate higher priority. For more information about setting task priority, see Setting Task Priority in the Amazon Simple Workflow Developer Guide.
    • :input - (String) The input for the workflow execution. This is a free form string which should be meaningful to the workflow you are starting. This input is made available to the new workflow execution in the WorkflowExecutionStarted history event.
    • :execution_start_to_close_timeout - (String) The total duration for this workflow execution. This overrides the defaultExecutionStartToCloseTimeout specified when registering the workflow type. The duration is specified in seconds; an integer greater than or equal to 0. Exceeding this limit will cause the workflow execution to time out. Unlike some of the other timeout parameters in Amazon SWF, you cannot specify a value of "NONE" for this timeout; there is a one-year max limit on the time that a workflow execution can run. An execution start-to-close timeout must be specified either through this parameter or as a default when the workflow type is registered. If neither this parameter nor a default execution start-to-close timeout is specified, a fault is returned.
    • :tag_list - (Array<) The list of tags to associate with the workflow execution. You can specify a maximum of 5 tags. You can list workflow executions with a specific tag by calling ListOpenWorkflowExecutions or ListClosedWorkflowExecutions and specifying a TagFilter.
    • :task_start_to_close_timeout - (String) Specifies the maximum duration of decision tasks for this workflow execution. This parameter overrides the defaultTaskStartToCloseTimout specified when registering the workflow type using RegisterWorkflowType. The duration is specified in seconds; an integer greater than or equal to 0. The value "NONE" can be used to specify unlimited duration. A task start-to-close timeout for this workflow execution must be specified either as a default for the workflow type or through this parameter. If neither this parameter is set nor a default task start-to-close timeout was specified at registration time then a fault will be returned.
    • :child_policy - (String) If set, specifies the policy to use for the child workflow executions of this workflow execution if it is terminated, by calling the TerminateWorkflowExecution action explicitly or due to an expired timeout. This policy overrides the default child policy specified when registering the workflow type using RegisterWorkflowType. The supported child policies are: 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. A child policy for this workflow execution must be specified either as a default for the workflow type or through this parameter. If neither this parameter is set nor a default child policy was specified at registration time then a fault will be returned. Valid values include:
      • TERMINATE
      • REQUEST_CANCEL
      • ABANDON

Returns:

  • (Core::Response) —

    The #data method of the response object returns a hash with the following structure:

    • runId - (String)

#terminate_workflow_execution(options = {}) ⇒ Core::Response

Calls the TerminateWorkflowExecution API operation.

Parameters:

  • options (Hash) (defaults to: {}) —
    • :domain - required - (String) The domain of the workflow execution to terminate.
    • :workflow_id - required - (String) The workflowId of the workflow execution to terminate.
    • :run_id - (String) The runId of the workflow execution to terminate.
    • :reason - (String) Optional. A descriptive reason for terminating the workflow execution.
    • :details - (String) Optional. Details for terminating the workflow execution.
    • :child_policy - (String) If set, specifies the policy to use for the child workflow executions of the workflow execution being terminated. This policy overrides the child policy specified for the workflow execution at registration time or when starting the execution. The supported child policies are: 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. A child policy for this workflow execution must be specified either as a default for the workflow type or through this parameter. If neither this parameter is set nor a default child policy was specified at registration time then a fault will be returned. Valid values include:
      • TERMINATE
      • REQUEST_CANCEL
      • ABANDON

Returns: