1. /**
  2. * Teardowns task queues for backward compatibility with rate limiting.
  3. * This function is designed to gracefully shut down task queues, ensuring
  4. * that existing tasks are handled and future tasks are not processed
  5. * after a specified point.
  6. *
  7. * @param {Object} taskQueues - An object containing the task queues to be shut down.
  8. * Expected to have a structure where keys are queue names
  9. * and values are functions that manage the queue.
  10. */
  11. function teardownTaskQueues(taskQueues) {
  12. if (!taskQueues) {
  13. console.warn("teardownTaskQueues: taskQueues is null or undefined. No queues to teardown.");
  14. return;
  15. }
  17. for (const queueName in taskQueues) {
  18. if (taskQueues.hasOwnProperty(queueName)) {
  19. const queue = taskQueues[queueName];
  21. if (typeof queue.stop === 'function') {
  22. queue.stop(); // Stop processing new tasks
  23. console.log(`teardownTaskQueues: Stopped queue ${queueName}`);
  24. } else {
  25. console.warn(`teardownTaskQueues: Queue ${queueName} does not have a 'stop' method. Cannot stop processing.`);
  26. }
  28. if (typeof queue.clear === 'function') {
  29. queue.clear(); // Clear any remaining tasks in the queue
  30. console.log(`teardownTaskQueues: Cleared queue ${queueName}`);
  31. } else {
  32. console.warn(`teardownTaskQueues: Queue ${queueName} does not have a 'clear' method. Cannot clear tasks.`);
  33. }
  34. }
  35. }
  36. }

Add your comment