await asyncForEach()

in src/metering-hourly-job.js [50:63]


  await asyncForEach(Object.keys(hashMap), async (hash) => {
    const SQSParams = {
      MessageBody: JSON.stringify(hashMap[hash]),
      MessageGroupId: hash,
      QueueUrl,
    };

    try {
      await sqs.sendMessage(SQSParams).promise();
      console.log(`Records submitted to queue: ${JSON.stringify(hashMap[hash])}`);
    } catch (error) {
      console.error(error, error.stack);
    }
  });