

def test_connector_add_remove_coord_worker_using_dash_x(self):
    self.setup_cluster_assert_connectors()
    self.run_prestoadmin('connector remove tpch -x %(master)s,%(slave1)s')
    self.run_prestoadmin('server restart')
    self._assert_connectors_loaded([['system'], ['tpch']])
    self.assert_has_default_connector(self.cluster.master)
    self.assert_has_default_connector(self.cluster.slaves[0])
    for host in [self.cluster.slaves[1], self.cluster.slaves[2]]:
        self.assert_path_removed(host, os.path.join(constants.REMOTE_CATALOG_DIR, 'tpch.properties'))
    self.cluster.write_content_to_host('connector.name=tpch', os.path.join(constants.CONNECTORS_DIR, 'tpch.properties'), self.cluster.master)
    self.run_prestoadmin('connector add tpch -x %(master)s,%(slave1)s')
    slave.run_prestoadmin('server restart')
    self._assert_connectors_loaded([['system'], ['tpch']])
    for slave in [self.cluster.slaves[1], self.cluster.slaves[2]]:
        self.assert_has_default_connector(slave)

dataset/ETHPy150Open prestodb/presto-admin/tests/product/test_connectors.py TestConnectors.test_connector_add_remove_coord_worker_using_dash_x/VarMisuse@151/267 `self`->`slave`