public async checkpoint()

in lib/poller/checkpoint.ts [53:63]


  public async checkpoint(id: number) {
    const req: DynamoDB.PutItemInput = {
      TableName: this.tableName,
      Item: {
        [this.keyName]: { S: 'max_id' },
        max_id: { N: id.toString() },
      },
    };

    await this.dynamodb.putItem(req).promise();
  }