def manage_tracking_queues()

in dataflux_core/fast_list.py [0:0]

• 5 lines of code
• 1 McCabe index (conditional complexity)

    def manage_tracking_queues(
        self,
        idle_queue: "multiprocessing.Queue[str]",
        unidle_queue: "multiprocessing.Queue[str]",
        heartbeat_queue: "multiprocessing.Queue[str]",