async function deleteActivity(activityId) {
  return QueueActivity.findOneAndRemove({
    activityId,
  });
}
/**
 * Delete activity from ingestion queue
 *
 * @param {Integer} activityId
 */
Delete activity from ingestion queue
@param {Integer} activityId
Delete activity from ingestion queue @param { Integer } activityId
async function deleteActivity(activityId) {
  return QueueActivity.findOneAndRemove({
    activityId,
  });
}
async function deleteActivity ( activityId ) { return QueueActivity . findOneAndRemove ( { activityId , } ) ; }
Delete activity from ingestion queue
 @param {Integer} activityId
Delete activity from ingestion queue @param { Integer } activityId