Proper way to shutdown on SIGTERM/SIGINT

Community Support
1

What’s the proper way to shutdown on a SIGTERM/SIGINT? What I have right now is

export default async function run() {
  process.on('SIGTERM', async () => {
    logger.info('Received SIGTERM');
    await workerPromise;
    await connection.close();
    process.exit(0);
  });
  connection = await NativeConnection.connect();
  const worker = await Worker.create({
    activities: getAllActivities(),
    connection,
    taskQueue: 'test',
  });
  workerPromise = worker.run();
  await workerPromise;
}

I originally also had worker.shutdown(), but my impression is that on a SIGINT/SIGTERM, the worker will automatically transition to a shutting down stage, so this isn’t necessary. Along those lines, if I await the workerPromise, do I also need to have another call to close the connection?

2

The worker already listens for these signals for you, you don’t need to do any of that.
You should close the connection though after the run promise is resolved.

See for reference:

3

So you’re saying that the revised block of code doesn’t need a listener for the SIGTERM? So instead it can just look like:

export default async function run() {
  connection = await NativeConnection.connect();
  const worker = await Worker.create({
    activities: getAllActivities(),
    connection,
    taskQueue: 'test',
  });
  workerPromise = worker.run();
  await workerPromise;
  await connection.close();
  // any other things I might want to handle here like closing other DB connections
}

Also I’m not completely clear on what the docs you linked are supposed to indicate, could you elaborate? I thought made more sense, but perhaps I’m not understanding completely. Thanks!

4

So instead it can just look like:

Yes

Also I’m not completely clear on what the docs you linked are supposed to indicate, could you elaborate?

Just that you can customize the default signals if you’d like:

image

1 Like