

def test_connector_add_lost_host(self):
    installer = StandalonePrestoInstaller(self)
    self.setup_cluster(NoHadoopBareImageProvider(), self.PA_ONLY_CLUSTER)
    self.upload_topology()
    installer.install()
    self.run_prestoadmin('connector remove tpch')
    self.cluster.stop_host(self.cluster.slaves[0])
    self.cluster.write_content_to_host('connector.name=tpch', os.path.join(constants.CONNECTORS_DIR, 'tpch.properties'), self.cluster.master)
    output = self.run_prestoadmin('connector add tpch', raise_error=False)
    for host in self.cluster.all_internal_hosts():
        deploying_message = 'Deploying tpch.properties connector configurations on: %s'
        self.assertTrue(((deploying_message % host) in output), ('expected %s \n actual %s' % ((deploying_message % host), output)))
    self.assertRegexpMatches(output, self.down_node_connection_error(installer.cluster.internal_slaves[0]))
    self.assertEqual(len(output.splitlines()), (len(self.cluster.all_hosts()) + self.len_down_node_error))
    self.run_prestoadmin('server start', raise_error=False)
    for host in [self.cluster.master, self.cluster.slaves[1], self.cluster.slaves[2]]:
        self.assert_has_default_connector(host)
    self._assert_connectors_loaded([['system'], ['tpch']])

dataset/ETHPy150Open prestodb/presto-admin/tests/product/test_connectors.py TestConnectors.test_connector_add_lost_host/VarMisuse@163/278 `self`->`installer`