# Copyright 2011-2012 Amazon.com, Inc. or its affiliates. All Rights Reserved. # # Licensed under the Apache License, Version 2.0 (the "License"). You # may not use this file except in compliance with the License. A copy of # the License is located at # # http://aws.amazon.com/apache2.0/ # # or in the "license" file accompanying this file. This file is # distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF # ANY KIND, either express or implied. See the License for the specific # language governing permissions and limitations under the License. module AWS class SimpleWorkflow # Client class for Amazon Simple Workflow Service (SWF). class Client < Core::Client API_VERSION = '2012-01-25' extend Core::JSONClient # @private TARGET_PREFIX = "SimpleWorkflowService." # @private CACHEABLE_REQUESTS = Set[ :count_pending_activity_tasks, :count_pending_decision_tasks, :count_closed_workflow_executions, :count_open_workflow_executions, :describe_activity_type, :describe_domain, :describe_workflow_execution, :describe_workflow_type, :get_workflow_execution_history, #:poll_for_decision_task, # see below for expanded logic :list_activity_types, :list_domains, :list_closed_workfow_executions, :list_open_workfow_executions, :list_workfow_types, ] ## client methods ## # Calls the CountClosedWorkflowExecutions API operation. # @method count_closed_workflow_executions(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:start_time_filter+ - (Hash) # * +:oldest_date+ - *required* - (Integer) # * +:latest_date+ - (Integer) # * +:close_time_filter+ - (Hash) # * +:oldest_date+ - *required* - (Integer) # * +:latest_date+ - (Integer) # * +:execution_filter+ - (Hash) # * +:workflow_id+ - *required* - (String) # * +:type_filter+ - (Hash) # * +:name+ - *required* - (String) # * +:version+ - (String) # * +:tag_filter+ - (Hash) # * +:tag+ - *required* - (String) # * +:close_status_filter+ - (Hash) # * +:status+ - *required* - (String) # @return [Core::Response] # The #data method of the response object returns # a hash with the following structure: # * +count+ - (Integer) # * +truncated+ - (Boolean) define_client_method :count_closed_workflow_executions, 'CountClosedWorkflowExecutions' # Calls the CountOpenWorkflowExecutions API operation. # @method count_open_workflow_executions(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:start_time_filter+ - *required* - (Hash) # * +:oldest_date+ - *required* - (Integer) # * +:latest_date+ - (Integer) # * +:type_filter+ - (Hash) # * +:name+ - *required* - (String) # * +:version+ - (String) # * +:tag_filter+ - (Hash) # * +:tag+ - *required* - (String) # * +:execution_filter+ - (Hash) # * +:workflow_id+ - *required* - (String) # @return [Core::Response] # The #data method of the response object returns # a hash with the following structure: # * +count+ - (Integer) # * +truncated+ - (Boolean) define_client_method :count_open_workflow_executions, 'CountOpenWorkflowExecutions' # Calls the CountPendingActivityTasks API operation. # @method count_pending_activity_tasks(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:task_list+ - *required* - (Hash) # * +:name+ - *required* - (String) # @return [Core::Response] # The #data method of the response object returns # a hash with the following structure: # * +count+ - (Integer) # * +truncated+ - (Boolean) define_client_method :count_pending_activity_tasks, 'CountPendingActivityTasks' # Calls the CountPendingDecisionTasks API operation. # @method count_pending_decision_tasks(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:task_list+ - *required* - (Hash) # * +:name+ - *required* - (String) # @return [Core::Response] # The #data method of the response object returns # a hash with the following structure: # * +count+ - (Integer) # * +truncated+ - (Boolean) define_client_method :count_pending_decision_tasks, 'CountPendingDecisionTasks' # Calls the DeprecateActivityType API operation. # @method deprecate_activity_type(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:activity_type+ - *required* - (Hash) # * +:name+ - *required* - (String) # * +:version+ - *required* - (String) # @return [Core::Response] define_client_method :deprecate_activity_type, 'DeprecateActivityType' # Calls the DeprecateDomain API operation. # @method deprecate_domain(options = {}) # @param [Hash] options # * +:name+ - *required* - (String) # @return [Core::Response] define_client_method :deprecate_domain, 'DeprecateDomain' # Calls the DeprecateWorkflowType API operation. # @method deprecate_workflow_type(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:workflow_type+ - *required* - (Hash) # * +:name+ - *required* - (String) # * +:version+ - *required* - (String) # @return [Core::Response] define_client_method :deprecate_workflow_type, 'DeprecateWorkflowType' # Calls the DescribeActivityType API operation. # @method describe_activity_type(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:activity_type+ - *required* - (Hash) # * +:name+ - *required* - (String) # * +:version+ - *required* - (String) # @return [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) # * +defaultTaskScheduleToStartTimeout+ - (String) # * +defaultTaskScheduleToCloseTimeout+ - (String) define_client_method :describe_activity_type, 'DescribeActivityType' # Calls the DescribeDomain API operation. # @method describe_domain(options = {}) # @param [Hash] options # * +:name+ - *required* - (String) # @return [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) define_client_method :describe_domain, 'DescribeDomain' # Calls the DescribeWorkflowExecution API operation. # @method describe_workflow_execution(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:execution+ - *required* - (Hash) # * +:workflow_id+ - *required* - (String) # * +:run_id+ - *required* - (String) # @return [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) # * +childPolicy+ - (String) # * +openCounts+ - (Hash) # * +openActivityTasks+ - (Integer) # * +openDecisionTasks+ - (Integer) # * +openTimers+ - (Integer) # * +openChildWorkflowExecutions+ - (Integer) # * +latestActivityTaskTimestamp+ - (Time) # * +latestExecutionContext+ - (String) define_client_method :describe_workflow_execution, 'DescribeWorkflowExecution' # Calls the DescribeWorkflowType API operation. # @method describe_workflow_type(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:workflow_type+ - *required* - (Hash) # * +:name+ - *required* - (String) # * +:version+ - *required* - (String) # @return [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) # * +defaultChildPolicy+ - (String) define_client_method :describe_workflow_type, 'DescribeWorkflowType' # Calls the GetWorkflowExecutionHistory API operation. # @method get_workflow_execution_history(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:execution+ - *required* - (Hash) # * +:workflow_id+ - *required* - (String) # * +:run_id+ - *required* - (String) # * +:next_page_token+ - (String) # * +:maximum_page_size+ - (Integer) # * +:reverse_order+ - (Boolean) # @return [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) # * +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) # * +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) # * +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) # * +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) # * +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) # * +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) # * +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) # * +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) # * +nextPageToken+ - (String) define_client_method :get_workflow_execution_history, 'GetWorkflowExecutionHistory' # Calls the ListActivityTypes API operation. # @method list_activity_types(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:name+ - (String) # * +:registration_status+ - *required* - (String) # * +:next_page_token+ - (String) # * +:maximum_page_size+ - (Integer) # * +:reverse_order+ - (Boolean) # @return [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) define_client_method :list_activity_types, 'ListActivityTypes' # Calls the ListClosedWorkflowExecutions API operation. # @method list_closed_workflow_executions(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:start_time_filter+ - (Hash) # * +:oldest_date+ - *required* - (Integer) # * +:latest_date+ - (Integer) # * +:close_time_filter+ - (Hash) # * +:oldest_date+ - *required* - (Integer) # * +:latest_date+ - (Integer) # * +:execution_filter+ - (Hash) # * +:workflow_id+ - *required* - (String) # * +:close_status_filter+ - (Hash) # * +:status+ - *required* - (String) # * +:type_filter+ - (Hash) # * +:name+ - *required* - (String) # * +:version+ - (String) # * +:tag_filter+ - (Hash) # * +:tag+ - *required* - (String) # * +:next_page_token+ - (String) # * +:maximum_page_size+ - (Integer) # * +:reverse_order+ - (Boolean) # @return [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) define_client_method :list_closed_workflow_executions, 'ListClosedWorkflowExecutions' # Calls the ListDomains API operation. # @method list_domains(options = {}) # @param [Hash] options # * +:next_page_token+ - (String) # * +:registration_status+ - *required* - (String) # * +:maximum_page_size+ - (Integer) # * +:reverse_order+ - (Boolean) # @return [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) define_client_method :list_domains, 'ListDomains' # Calls the ListOpenWorkflowExecutions API operation. # @method list_open_workflow_executions(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:start_time_filter+ - *required* - (Hash) # * +:oldest_date+ - *required* - (Integer) # * +:latest_date+ - (Integer) # * +:type_filter+ - (Hash) # * +:name+ - *required* - (String) # * +:version+ - (String) # * +:tag_filter+ - (Hash) # * +:tag+ - *required* - (String) # * +:next_page_token+ - (String) # * +:maximum_page_size+ - (Integer) # * +:reverse_order+ - (Boolean) # * +:execution_filter+ - (Hash) # * +:workflow_id+ - *required* - (String) # @return [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) define_client_method :list_open_workflow_executions, 'ListOpenWorkflowExecutions' # Calls the ListWorkflowTypes API operation. # @method list_workflow_types(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:name+ - (String) # * +:registration_status+ - *required* - (String) # * +:next_page_token+ - (String) # * +:maximum_page_size+ - (Integer) # * +:reverse_order+ - (Boolean) # @return [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) define_client_method :list_workflow_types, 'ListWorkflowTypes' # Calls the PollForActivityTask API operation. # @method poll_for_activity_task(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:task_list+ - *required* - (Hash) # * +:name+ - *required* - (String) # * +:identity+ - (String) # @return [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) define_client_method :poll_for_activity_task, 'PollForActivityTask' # Calls the PollForDecisionTask API operation. # @method poll_for_decision_task(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:task_list+ - *required* - (Hash) # * +:name+ - *required* - (String) # * +:identity+ - (String) # * +:next_page_token+ - (String) # * +:maximum_page_size+ - (Integer) # * +:reverse_order+ - (Boolean) # @return [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) # * +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) # * +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) # * +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) # * +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) # * +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) # * +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) # * +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) # * +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) # * +nextPageToken+ - (String) # * +previousStartedEventId+ - (Integer) define_client_method :poll_for_decision_task, 'PollForDecisionTask' # Calls the RecordActivityTaskHeartbeat API operation. # @method record_activity_task_heartbeat(options = {}) # @param [Hash] options # * +:task_token+ - *required* - (String) # * +:details+ - (String) # @return [Core::Response] # The #data method of the response object returns # a hash with the following structure: # * +cancelRequested+ - (Boolean) define_client_method :record_activity_task_heartbeat, 'RecordActivityTaskHeartbeat' # Calls the RegisterActivityType API operation. # @method register_activity_type(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:name+ - *required* - (String) # * +:version+ - *required* - (String) # * +:description+ - (String) # * +:default_task_start_to_close_timeout+ - (String) # * +:default_task_heartbeat_timeout+ - (String) # * +:default_task_list+ - (Hash) # * +:name+ - *required* - (String) # * +:default_task_schedule_to_start_timeout+ - (String) # * +:default_task_schedule_to_close_timeout+ - (String) # @return [Core::Response] define_client_method :register_activity_type, 'RegisterActivityType' # Calls the RegisterDomain API operation. # @method register_domain(options = {}) # @param [Hash] options # * +:name+ - *required* - (String) # * +:description+ - (String) # * +:workflow_execution_retention_period_in_days+ - *required* - (String) # @return [Core::Response] define_client_method :register_domain, 'RegisterDomain' # Calls the RegisterWorkflowType API operation. # @method register_workflow_type(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:name+ - *required* - (String) # * +:version+ - *required* - (String) # * +:description+ - (String) # * +:default_task_start_to_close_timeout+ - (String) # * +:default_execution_start_to_close_timeout+ - (String) # * +:default_task_list+ - (Hash) # * +:name+ - *required* - (String) # * +:default_child_policy+ - (String) # @return [Core::Response] define_client_method :register_workflow_type, 'RegisterWorkflowType' # Calls the RequestCancelWorkflowExecution API operation. # @method request_cancel_workflow_execution(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:workflow_id+ - *required* - (String) # * +:run_id+ - (String) # @return [Core::Response] define_client_method :request_cancel_workflow_execution, 'RequestCancelWorkflowExecution' # Calls the RespondActivityTaskCanceled API operation. # @method respond_activity_task_canceled(options = {}) # @param [Hash] options # * +:task_token+ - *required* - (String) # * +:details+ - (String) # @return [Core::Response] define_client_method :respond_activity_task_canceled, 'RespondActivityTaskCanceled' # Calls the RespondActivityTaskCompleted API operation. # @method respond_activity_task_completed(options = {}) # @param [Hash] options # * +:task_token+ - *required* - (String) # * +:result+ - (String) # @return [Core::Response] define_client_method :respond_activity_task_completed, 'RespondActivityTaskCompleted' # Calls the RespondActivityTaskFailed API operation. # @method respond_activity_task_failed(options = {}) # @param [Hash] options # * +:task_token+ - *required* - (String) # * +:reason+ - (String) # * +:details+ - (String) # @return [Core::Response] define_client_method :respond_activity_task_failed, 'RespondActivityTaskFailed' # Calls the RespondDecisionTaskCompleted API operation. # @method respond_decision_task_completed(options = {}) # @param [Hash] options # * +:task_token+ - *required* - (String) # * +:decisions+ - (Array) # * +:decision_type+ - *required* - (String) # * +: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) # * +: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_start_to_close_timeout+ - (String) # * +:child_policy+ - (String) # * +: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_start_to_close_timeout+ - (String) # * +:child_policy+ - (String) # * +:tag_list+ - (Array) # * +:execution_context+ - (String) # @return [Core::Response] define_client_method :respond_decision_task_completed, 'RespondDecisionTaskCompleted' # Calls the SignalWorkflowExecution API operation. # @method signal_workflow_execution(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:workflow_id+ - *required* - (String) # * +:run_id+ - (String) # * +:signal_name+ - *required* - (String) # * +:input+ - (String) # @return [Core::Response] define_client_method :signal_workflow_execution, 'SignalWorkflowExecution' # Calls the StartWorkflowExecution API operation. # @method start_workflow_execution(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:workflow_id+ - *required* - (String) # * +:workflow_type+ - *required* - (Hash) # * +:name+ - *required* - (String) # * +:version+ - *required* - (String) # * +:task_list+ - (Hash) # * +:name+ - *required* - (String) # * +:input+ - (String) # * +:execution_start_to_close_timeout+ - (String) # * +:tag_list+ - (Array) # * +:task_start_to_close_timeout+ - (String) # * +:child_policy+ - (String) # @return [Core::Response] # The #data method of the response object returns # a hash with the following structure: # * +runId+ - (String) define_client_method :start_workflow_execution, 'StartWorkflowExecution' # Calls the TerminateWorkflowExecution API operation. # @method terminate_workflow_execution(options = {}) # @param [Hash] options # * +:domain+ - *required* - (String) # * +:workflow_id+ - *required* - (String) # * +:run_id+ - (String) # * +:reason+ - (String) # * +:details+ - (String) # * +:child_policy+ - (String) # @return [Core::Response] define_client_method :terminate_workflow_execution, 'TerminateWorkflowExecution' ## end client methods ## protected def cacheable_request? name, options if name == :poll_for_decision_task options.keys.include?(:next_page_token) else self.class::CACHEABLE_REQUESTS.include?(name) end end end end end