Scheduled-on-deletion-processing.js

const publishToKinesis = async (payload) => {
  // Publishing logic here which is irrelevant now
};

// NOTE : Although I believe that this code is mostly correct, I confess that I never ran it
// so it may contain some minor syntax errors or something like that....
export const handler = ({ Records: dynamoDbRecords }) => {
  const promises = dynamoDbRecords.map(({ dynamodb: { OldImage: oldImage } }) => {
    if (oldImage && oldImage.recordType === 'STATUS_TASK') { // We interested only in deleted records of type STATUS_TASK
      return oldImage;
    }
    return null;
  }).filter(r => r);
  await Promise.resolveAll(promises);
};