@aws-sdk/client-swf

Start a Workflow Execution

This feature allows you to start a new workflow execution in a specified domain. You need to provide the domain, workflow ID, workflow type, task list, and any input data required for the workflow.

const { SWFClient, StartWorkflowExecutionCommand } = require('@aws-sdk/client-swf');

const client = new SWFClient({ region: 'us-west-2' });

const params = {
  domain: 'example-domain',
  workflowId: 'example-workflow-id',
  workflowType: {
    name: 'example-workflow-type',
    version: '1.0'
  },
  taskList: { name: 'example-task-list' },
  input: JSON.stringify({ key: 'value' })
};

const command = new StartWorkflowExecutionCommand(params);

client.send(command).then(
  (data) => console.log('Workflow started:', data),
  (error) => console.error('Error starting workflow:', error)
);

Poll for a Decision Task

This feature allows you to poll for a decision task from a specified task list. Decision tasks are used to determine the next steps in a workflow execution.

const { SWFClient, PollForDecisionTaskCommand } = require('@aws-sdk/client-swf');

const client = new SWFClient({ region: 'us-west-2' });

const params = {
  domain: 'example-domain',
  taskList: { name: 'example-task-list' }
};

const command = new PollForDecisionTaskCommand(params);

client.send(command).then(
  (data) => console.log('Decision task:', data),
  (error) => console.error('Error polling for decision task:', error)
);

Respond to a Decision Task

This feature allows you to respond to a decision task by providing the task token and the decisions made. In this example, the decision is to complete the workflow execution with a specified result.

const { SWFClient, RespondDecisionTaskCompletedCommand } = require('@aws-sdk/client-swf');

const client = new SWFClient({ region: 'us-west-2' });

const params = {
  taskToken: 'example-task-token',
  decisions: [
    {
      decisionType: 'CompleteWorkflowExecution',
      completeWorkflowExecutionDecisionAttributes: {
        result: JSON.stringify({ key: 'value' })
      }
    }
  ]
};

const command = new RespondDecisionTaskCompletedCommand(params);

client.send(command).then(
  (data) => console.log('Decision task completed:', data),
  (error) => console.error('Error responding to decision task:', error)
);