@temporalio/common

Workflow Execution

This feature allows you to start a workflow execution using the Temporal client. The code sample demonstrates how to connect to the Temporal service and start a workflow.

const { WorkflowClient } = require('@temporalio/client');
const { Connection } = require('@temporalio/common');

async function run() {
  const connection = await Connection.connect();
  const client = new WorkflowClient(connection.service);
  const handle = await client.start('myWorkflow', { taskQueue: 'my-task-queue' });
  console.log(`Started workflow ${handle.workflowId}`);
}
run().catch(err => console.error(err));

Activity Definition

This feature allows you to define activities that can be executed within workflows. The code sample shows how to define a simple activity that takes an input and returns a greeting message.

const { defineActivity } = require('@temporalio/common');

const myActivity = defineActivity(async (input) => {
  return `Hello, ${input.name}!`;
});

module.exports = { myActivity };

Workflow Definition

This feature allows you to define workflows that orchestrate the execution of activities. The code sample demonstrates how to define a workflow that calls an activity and returns its result.

const { defineWorkflow } = require('@temporalio/common');
const { myActivity } = require('./activities');

const myWorkflow = defineWorkflow(async (input) => {
  const result = await myActivity({ name: input.name });
  return result;
});

module.exports = { myWorkflow };