Method start

packages/queue/src/helpers/keep-alive.ts:12–22

()

  }

  start() {
    this.intervalID = setInterval(async () => {
      await this.helpers.withPgClient((pgClient) =>
        pgClient.query(
          `UPDATE graphile_worker.jobs SET locked_at=$1 WHERE id=$2`,
          [new Date(), this.helpers.job.id]
        )
      );
      this.helpers.logger.info('keep alive');
    }, this.interval);
  }

  end() {
    clearInterval(this.intervalID);