def test_starts_cluster_state_service(self):
        reactor = MemoryCoreReactor()
        self.script.main(reactor, self.options)
        server = reactor.tcpServers[0]
        control_resource = server[1].wrappedFactory.resource
        service = control_resource._v1_user.cluster_state_service
        self.assertEqual((service.__class__, service.running),
                         (ClusterStateService, True))
``ControlScript.main`` starts a cluster state service.
dataset/ETHPy150Open ClusterHQ/flocker/flocker/control/test/test_script.py/ControlScriptTests.test_starts_cluster_state_service