def garbage_collect_noncompliant()

in src/python/detectors/multiprocessing_garbage_collection_prevention/multiprocessing_garbage_collection_prevention.py [0:0]


def garbage_collect_noncompliant(self):
    from multiprocessing import Pipe
    pipe = Pipe()
    try:
        # Trigger a refresh.
        self.assertFalse(
            client._MongoReplicaSetClient__monitor.isAlive())

        client.disconnect()
        self.assertSoon(
            lambda: client._MongoReplicaSetClient__monitor.isAlive())

        client.db.collection.find_one()
    except Exception:
        traceback.print_exc()
        pipe.send(True)