def test_configures_cluster(self):
        result = self._send_configuration()
        apps = FlockerConfiguration(
            deepcopy(COMPLEX_APPLICATION_YAML)).applications()
        expected = model_from_configuration(
            deployment_state=self.cluster_state_service.as_deployment(),
            applications=apps,
            deployment_configuration=deepcopy(COMPLEX_DEPLOYMENT_YAML))
        result.addCallback(lambda _: self.assertEqual(
            self.persistence_service.get(), expected))
        return result
Local purge implementation of TaskQueueService.PurgeQueue.
dataset/ETHPy150Open ClusterHQ/flocker/flocker/cli/functional/test_deploy_script.py/FlockerDeployTests.test_configures_cluster--crossover with--dataset/ETHPy150Open AppScale/appscale/AppServer/google/appengine/api/taskqueue/taskqueue_stub.py/TaskQueueServiceStub._Dynamic_PurgeQueue