1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
"""Test index opening functionality"""
# pylint: disable=C0115, C0116, invalid-name
import os
import warnings
from elasticsearch8.exceptions import ElasticsearchWarning
from . import CuratorTestCase
from . import testvars
HOST = os.environ.get('TEST_ES_SERVER', 'http://127.0.0.1:9200')
MET = 'metadata'
class TestActionFileOpenClosed(CuratorTestCase):
def test_open_closed(self):
self.write_config(self.args['configfile'], testvars.client_config.format(HOST))
self.write_config(
self.args['actionfile'], testvars.optionless_proto.format('open')
)
idx1, idx2 = ('dummy', 'my_index')
self.create_index(idx1)
self.create_index(idx2)
# ElasticsearchWarning: the default value for the wait_for_active_shards
# parameter will change from '0' to 'index-setting' in version 8;
# specify 'wait_for_active_shards=index-setting' to adopt the future default
# behaviour, or 'wait_for_active_shards=0' to preserve today's behaviour
warnings.filterwarnings("ignore", category=ElasticsearchWarning)
self.client.indices.close(index=idx2, ignore_unavailable=True)
self.invoke_runner()
csi = self.client.cluster.state(metric=MET)[MET]['indices']
for idx in (idx1, idx2):
assert 'close' != csi[idx]['state']
def test_extra_option(self):
self.write_config(self.args['configfile'], testvars.client_config.format(HOST))
self.write_config(
self.args['actionfile'], testvars.bad_option_proto_test.format('open')
)
idx1, idx2 = ('dummy', 'my_index')
self.create_index(idx1)
self.create_index(idx2)
# ElasticsearchWarning: the default value for the wait_for_active_shards
# parameter will change from '0' to 'index-setting' in version 8;
# specify 'wait_for_active_shards=index-setting' to adopt the future default
# behaviour, or 'wait_for_active_shards=0' to preserve today's behaviour
warnings.filterwarnings("ignore", category=ElasticsearchWarning)
self.client.indices.close(index=idx2, ignore_unavailable=True)
self.invoke_runner()
csi = self.client.cluster.state(metric=MET)[MET]['indices']
assert 'close' != csi[idx1]['state']
assert 'close' == csi[idx2]['state']
assert 1 == self.result.exit_code
class TestCLIOpenClosed(CuratorTestCase):
def test_open_closed(self):
idx1, idx2 = ('dummy', 'my_index')
self.create_index(idx1)
self.create_index(idx2)
# ElasticsearchWarning: the default value for the wait_for_active_shards
# parameter will change from '0' to 'index-setting' in version 8;
# specify 'wait_for_active_shards=index-setting' to adopt the future default
# behaviour, or 'wait_for_active_shards=0' to preserve today's behaviour
warnings.filterwarnings("ignore", category=ElasticsearchWarning)
self.client.indices.close(index=idx2, ignore_unavailable=True)
args = self.get_runner_args()
args += [
'--config',
self.args['configfile'],
'open',
'--filter_list',
'{"filtertype":"pattern","kind":"prefix","value":"my"}',
]
assert 0 == self.run_subprocess(
args, logname='TestCLIOpenClosed.test_open_closed'
)
csi = self.client.cluster.state(metric=MET)[MET]['indices']
for idx in (idx1, idx2):
assert 'close' != csi[idx]['state']
|
