The Amazon Simple Workflow Service (Amazon SWF) makes it easy to build applications that use Amazon's cloud to coordinate work across distributed components. In Amazon SWF, a task represents a logical unit of work that is performed by a component of your workflow. Coordinating tasks in a workflow involves managing intertask dependencies, scheduling, and concurrency in accordance with the logical flow of the application.
Amazon SWF gives you full control over implementing tasks and coordinating them without worrying about underlying complexities such as tracking their progress and maintaining their state.
This documentation serves as reference only. For a broader overview of the Amazon SWF programming model, see the Amazon SWF Developer Guide .
swf(config = list())
Optional configuration of credentials, endpoint, and/or region.
svc <- swf( config = list( credentials = list( creds = list( access_key_id = "string", secret_access_key = "string", session_token = "string" ), profile = "string" ), endpoint = "string", region = "string" ) )
count_closed_workflow_executions | Returns the number of closed workflow executions within the given domain that meet the specified filtering criteria |
count_open_workflow_executions | Returns the number of open workflow executions within the given domain that meet the specified filtering criteria |
count_pending_activity_tasks | Returns the estimated number of activity tasks in the specified task list |
count_pending_decision_tasks | Returns the estimated number of decision tasks in the specified task list |
deprecate_activity_type | Deprecates the specified activity type |
deprecate_domain | Deprecates the specified domain |
deprecate_workflow_type | Deprecates the specified workflow type |
describe_activity_type | Returns information about the specified activity type |
describe_domain | Returns information about the specified domain, including description and status |
describe_workflow_execution | Returns information about the specified workflow execution including its type and some statistics |
describe_workflow_type | Returns information about the specified workflow type |
get_workflow_execution_history | Returns the history of the specified workflow execution |
list_activity_types | Returns information about all activities registered in the specified domain that match the specified name and registration status |
list_closed_workflow_executions | Returns a list of closed workflow executions in the specified domain that meet the filtering criteria |
list_domains | Returns the list of domains registered in the account |
list_open_workflow_executions | Returns a list of open workflow executions in the specified domain that meet the filtering criteria |
list_tags_for_resource | List tags for a given domain |
list_workflow_types | Returns information about workflow types in the specified domain |
poll_for_activity_task | Used by workers to get an ActivityTask from the specified activity taskList |
poll_for_decision_task | Used by deciders to get a DecisionTask from the specified decision taskList |
record_activity_task_heartbeat | Used by activity workers to report to the service that the ActivityTask represented by the specified taskToken is still making progress |
register_activity_type | Registers a new activity type along with its configuration settings in the specified domain |
register_domain | Registers a new domain |
register_workflow_type | Registers a new workflow type and its configuration settings in the specified domain |
request_cancel_workflow_execution | Records a WorkflowExecutionCancelRequested event in the currently running workflow execution identified by the given domain, workflowId, and runId |
respond_activity_task_canceled | Used by workers to tell the service that the ActivityTask identified by the taskToken was successfully canceled |
respond_activity_task_completed | Used by workers to tell the service that the ActivityTask identified by the taskToken completed successfully with a result (if provided) |
respond_activity_task_failed | Used by workers to tell the service that the ActivityTask identified by the taskToken has failed with reason (if specified) |
respond_decision_task_completed | Used by deciders to tell the service that the DecisionTask identified by the taskToken has successfully completed |
signal_workflow_execution | Records a WorkflowExecutionSignaled event in the workflow execution history and creates a decision task for the workflow execution identified by the given domain, workflowId and runId |
start_workflow_execution | Starts an execution of the workflow type in the specified domain using the provided workflowId and input data |
tag_resource | Add a tag to a Amazon SWF domain |
terminate_workflow_execution | Records a WorkflowExecutionTerminated event and forces closure of the workflow execution identified by the given domain, runId, and workflowId |
undeprecate_activity_type | Undeprecates a previously deprecated activity type |
undeprecate_domain | Undeprecates a previously deprecated domain |
undeprecate_workflow_type | Undeprecates a previously deprecated workflow type |
# NOT RUN {
svc <- swf()
svc$count_closed_workflow_executions(
Foo = 123
)
# }
# NOT RUN {
# }
Run the code above in your browser using DataLab