const handleEntities = async (db: Db, batchSize: number) => {
  const entitiesCollection = db.collection('entities');
  const entityCursor = entitiesCollection.find({});

  while (await entityCursor.hasNext()) {