1. import json
  2. import inspect
  3. from queue import Queue
  5. def serialize_queue(queue, dry_run=False):
  6. """Serializes a queue object for diagnostics.
  8. Args:
  9. queue: The queue object to serialize.
  10. dry_run: If True, only prints the code that would be executed.
  11. If False, actually serializes and returns the string.
  13. Returns:
  14. A string representation of the queue object, or None if dry_run is True.
  15. """
  17. if dry_run:
  18. print("Dry run mode: Printing code to be executed.")
  19. code = f"""
  20. queue_data = {{
  21. 'q': {repr(queue.queue)},
  22. 'qsize': {repr(queue.qsize)},
  23. 'is_empty': {repr(queue.empty())},
  24. 'maxsize': {repr(queue.maxsize)}
  25. }}
  26. return json.dumps(queue_data)
  27. """
  28. return None
  29. else:
  30. queue_data = {
  31. 'q': queue.queue,
  32. 'qsize': queue.qsize,
  33. 'is_empty': queue.empty(),
  34. 'maxsize': queue.maxsize
  35. }
  36. return json.dumps(queue_data, indent=4) # indent for readability
  40. if __name__ == '__main__':
  41. # Example Usage
  42. q = Queue()
  43. q.put(1)
  44. q.put(2)
  45. q.put(3)
  47. # Serialize with dry-run
  48. serialize_queue(q, dry_run=True)
  50. # Serialize without dry-run
  51. serialized_string = serialize_queue(q)
  52. print(serialized_string)

Add your comment