[FEA]: Replace multiprocessing.Queue usage in python/morpheus/morpheus/utils/logger.py

[dagardner-nv]

Is this a new feature, an improvement, or a change to existing functionality?

Improvement

How would you describe the priority of this feature request

High

Please provide a clear description of problem this feature solves

Currently this class is raising a NotImplementedError on some platforms specifically on Arm64. This is a known issue in cpython (python/cpython#101094) and doesn't appear to be getting fixed anytime soon.

Describe your ideal solution

Use our own FiberQueue class instead.

Additional context

The test tests/morpheus/utils/test_logger.py is currently being skipped on ARM and should be re-enabled once this issue is resolved.

Code of Conduct

• I agree to follow this project's Code of Conduct
• I have searched the open feature requests and have found no duplicates for this feature request

[dagardner-nv]

Turns out it was only a single unittest which was dependent upon the multiprocessing.Queue.qsize, and was easily worked-around by using the multiprocessing.Queue.empty method instead.

I did investigate using the FiberQueue class instead, however neither that class or the boost::fibers::buffered_channel class it encapsulates contains an empty or a size method. However it is possible that checking begin() == end() should be sufficient for implementing an empty method if we wanted to do so in the future.