@capture_logging(None)
    def test_cleanup_deletes_dataset(self, _logger):
        reactor = Clock()
        cluster = self.make_cluster(self.get_fake_flocker_client_instance())
        write_scenario = write_request_load_scenario(
            reactor, cluster, 5, sample_size=3
        )

        d = write_scenario.start()

        d.addCallback(write_scenario.stop)

        def list_datasets(ignored):
            return write_scenario.request.control_service.list_datasets_state()

        d.addCallback(list_datasets)

        def verify_dataset_has_been_deleted(datasets):
            self.assertEqual(datasets, [])

        d.addCallback(verify_dataset_has_been_deleted)
Routestopped configuration
dataset/ETHPy150Open ClusterHQ/flocker/benchmark/scenarios/test/test_write_request_load.py/write_request_load_scenarioTest.test_cleanup_deletes_dataset--crossover with--dataset/ETHPy150Open ronnix/fabtools/fabtools/require/shorewall.py/_routestopped_config