Class WorkerService

Run the connected worker; no-op (unnecessary to call)

Connects a worker to the mesh.

Example

import { MeshFlow } from '@hotmeshio/hotmesh';
import Redis from 'ioredis';
import * as workflows from './workflows';

async function run() {
  const worker = await MeshFlow.Worker.create({
    connection: {
      class: Redis,
      options: { host: 'redis', port: 6379 },
    },
    taskQueue: 'default',
    workflow: workflows.example,
  });

  await worker.run();
}
Copy