def waitForSync(self, predicate, *synchronizers):
        if not synchronizers:
            synchronizers = [self.synchronizer]

        ComputedGraph.assertHasGraph()
        passes = 0
        while passes < 100:
            for s in synchronizers:
                s.update()
            if predicate():
                break
            time.sleep(.1)
            passes += 1
        self.assertTrue(predicate())
dataset/ETHPy150Open ufora/ufora/ufora/cumulus/PersistentCache/PersistentCacheIndex_test.py/TestPersistentCacheIndex.waitForSync/original