def cleanup_processes()

in dataflux_core/fast_list.py [0:0]

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

    def cleanup_processes(
        self,
        processes: "list[multiprocessing.Process]",
        results_queue: "multiprocessing.Queue[set[tuple[str, int]]]",
        metadata_queue: "multiprocessing.Queue[tuple[str, int]]",
        results: "set[tuple[str, int]]",