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();
}