Skip to content

Commit 208269a

Browse files
sethmlarsonsethmlarson
committed
Switch to MutableMapping for headers/params
1 parent ec466bc commit 208269a

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

74 files changed

+1451
-1504
lines changed

‎elasticsearch/_async/client/__init__.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1977,7 +1977,7 @@ async def update_by_query(self, index, body=None, params=None, headers=None):
19771977
async def close_point_in_time(self, body=None, params=None, headers=None):
19781978
"""
19791979
Close a point in time
1980-
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/point-in-time.html>`_
1980+
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/point-in-time-api.html>`_
19811981
19821982
:arg body: a point-in-time id to close
19831983
"""
@@ -1991,7 +1991,7 @@ async def close_point_in_time(self, body=None, params=None, headers=None):
19911991
async def open_point_in_time(self, index=None, params=None, headers=None):
19921992
"""
19931993
Open a point in time that can be used in subsequent searches
1994-
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/point-in-time.html>`_
1994+
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/point-in-time-api.html>`_
19951995
19961996
:arg index: A comma-separated list of index names to open point
19971997
in time; use `_all` or empty string to perform the operation on all

‎elasticsearch/_async/client/__init__.pyi

Lines changed: 81 additions & 81 deletions
Large diffs are not rendered by default.

‎elasticsearch/_async/client/async_search.pyi

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
# specific language governing permissions and limitations
1616
# under the License.
1717

18-
from typing import Any, Mapping, Optional, Union, Collection
18+
from typing import Any, MutableMapping, Optional, Union, Collection
1919
from .utils import NamespacedClient
2020

2121
class AsyncSearchClient(NamespacedClient):
@@ -30,8 +30,8 @@ class AsyncSearchClient(NamespacedClient):
3030
request_timeout: Optional[Union[int, float]] = ...,
3131
ignore: Optional[Union[int, Collection[int]]] = ...,
3232
opaque_id: Optional[str] = ...,
33-
params: Optional[Mapping[str, Any]] = ...,
34-
headers: Optional[Mapping[str, str]] = ...,
33+
params: Optional[MutableMapping[str, Any]] = ...,
34+
headers: Optional[MutableMapping[str, str]] = ...,
3535
) -> Any: ...
3636
async def get(
3737
self,
@@ -47,8 +47,8 @@ class AsyncSearchClient(NamespacedClient):
4747
request_timeout: Optional[Union[int, float]] = ...,
4848
ignore: Optional[Union[int, Collection[int]]] = ...,
4949
opaque_id: Optional[str] = ...,
50-
params: Optional[Mapping[str, Any]] = ...,
51-
headers: Optional[Mapping[str, str]] = ...,
50+
params: Optional[MutableMapping[str, Any]] = ...,
51+
headers: Optional[MutableMapping[str, str]] = ...,
5252
) -> Any: ...
5353
async def submit(
5454
self,
@@ -103,6 +103,6 @@ class AsyncSearchClient(NamespacedClient):
103103
request_timeout: Optional[Union[int, float]] = ...,
104104
ignore: Optional[Union[int, Collection[int]]] = ...,
105105
opaque_id: Optional[str] = ...,
106-
params: Optional[Mapping[str, Any]] = ...,
107-
headers: Optional[Mapping[str, str]] = ...,
106+
params: Optional[MutableMapping[str, Any]] = ...,
107+
headers: Optional[MutableMapping[str, str]] = ...,
108108
) -> Any: ...

‎elasticsearch/_async/client/autoscaling.pyi

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
# specific language governing permissions and limitations
1616
# under the License.
1717

18-
from typing import Any, Mapping, Optional, Union, Collection
18+
from typing import Any, MutableMapping, Optional, Union, Collection
1919
from .utils import NamespacedClient
2020

2121
class AutoscalingClient(NamespacedClient):
@@ -29,8 +29,8 @@ class AutoscalingClient(NamespacedClient):
2929
request_timeout: Optional[Union[int, float]] = ...,
3030
ignore: Optional[Union[int, Collection[int]]] = ...,
3131
opaque_id: Optional[str] = ...,
32-
params: Optional[Mapping[str, Any]] = ...,
33-
headers: Optional[Mapping[str, str]] = ...,
32+
params: Optional[MutableMapping[str, Any]] = ...,
33+
headers: Optional[MutableMapping[str, str]] = ...,
3434
) -> Any: ...
3535
async def delete_autoscaling_policy(
3636
self,
@@ -43,8 +43,8 @@ class AutoscalingClient(NamespacedClient):
4343
request_timeout: Optional[Union[int, float]] = ...,
4444
ignore: Optional[Union[int, Collection[int]]] = ...,
4545
opaque_id: Optional[str] = ...,
46-
params: Optional[Mapping[str, Any]] = ...,
47-
headers: Optional[Mapping[str, str]] = ...,
46+
params: Optional[MutableMapping[str, Any]] = ...,
47+
headers: Optional[MutableMapping[str, str]] = ...,
4848
) -> Any: ...
4949
async def put_autoscaling_policy(
5050
self,
@@ -58,8 +58,8 @@ class AutoscalingClient(NamespacedClient):
5858
request_timeout: Optional[Union[int, float]] = ...,
5959
ignore: Optional[Union[int, Collection[int]]] = ...,
6060
opaque_id: Optional[str] = ...,
61-
params: Optional[Mapping[str, Any]] = ...,
62-
headers: Optional[Mapping[str, str]] = ...,
61+
params: Optional[MutableMapping[str, Any]] = ...,
62+
headers: Optional[MutableMapping[str, str]] = ...,
6363
) -> Any: ...
6464
async def get_autoscaling_policy(
6565
self,
@@ -72,6 +72,6 @@ class AutoscalingClient(NamespacedClient):
7272
request_timeout: Optional[Union[int, float]] = ...,
7373
ignore: Optional[Union[int, Collection[int]]] = ...,
7474
opaque_id: Optional[str] = ...,
75-
params: Optional[Mapping[str, Any]] = ...,
76-
headers: Optional[Mapping[str, str]] = ...,
75+
params: Optional[MutableMapping[str, Any]] = ...,
76+
headers: Optional[MutableMapping[str, str]] = ...,
7777
) -> Any: ...

‎elasticsearch/_async/client/cat.pyi

Lines changed: 51 additions & 51 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
# specific language governing permissions and limitations
1616
# under the License.
1717

18-
from typing import Any, Mapping, Optional, Union, Collection
18+
from typing import Any, MutableMapping, Optional, Union, Collection
1919
from .utils import NamespacedClient
2020

2121
class CatClient(NamespacedClient):
@@ -36,8 +36,8 @@ class CatClient(NamespacedClient):
3636
request_timeout: Optional[Union[int, float]] = ...,
3737
ignore: Optional[Union[int, Collection[int]]] = ...,
3838
opaque_id: Optional[str] = ...,
39-
params: Optional[Mapping[str, Any]] = ...,
40-
headers: Optional[Mapping[str, str]] = ...,
39+
params: Optional[MutableMapping[str, Any]] = ...,
40+
headers: Optional[MutableMapping[str, str]] = ...,
4141
) -> Any: ...
4242
async def allocation(
4343
self,
@@ -57,8 +57,8 @@ class CatClient(NamespacedClient):
5757
request_timeout: Optional[Union[int, float]] = ...,
5858
ignore: Optional[Union[int, Collection[int]]] = ...,
5959
opaque_id: Optional[str] = ...,
60-
params: Optional[Mapping[str, Any]] = ...,
61-
headers: Optional[Mapping[str, str]] = ...,
60+
params: Optional[MutableMapping[str, Any]] = ...,
61+
headers: Optional[MutableMapping[str, str]] = ...,
6262
) -> Any: ...
6363
async def count(
6464
self,
@@ -75,8 +75,8 @@ class CatClient(NamespacedClient):
7575
request_timeout: Optional[Union[int, float]] = ...,
7676
ignore: Optional[Union[int, Collection[int]]] = ...,
7777
opaque_id: Optional[str] = ...,
78-
params: Optional[Mapping[str, Any]] = ...,
79-
headers: Optional[Mapping[str, str]] = ...,
78+
params: Optional[MutableMapping[str, Any]] = ...,
79+
headers: Optional[MutableMapping[str, str]] = ...,
8080
) -> Any: ...
8181
async def health(
8282
self,
@@ -94,8 +94,8 @@ class CatClient(NamespacedClient):
9494
request_timeout: Optional[Union[int, float]] = ...,
9595
ignore: Optional[Union[int, Collection[int]]] = ...,
9696
opaque_id: Optional[str] = ...,
97-
params: Optional[Mapping[str, Any]] = ...,
98-
headers: Optional[Mapping[str, str]] = ...,
97+
params: Optional[MutableMapping[str, Any]] = ...,
98+
headers: Optional[MutableMapping[str, str]] = ...,
9999
) -> Any: ...
100100
async def help(
101101
self,
@@ -109,8 +109,8 @@ class CatClient(NamespacedClient):
109109
request_timeout: Optional[Union[int, float]] = ...,
110110
ignore: Optional[Union[int, Collection[int]]] = ...,
111111
opaque_id: Optional[str] = ...,
112-
params: Optional[Mapping[str, Any]] = ...,
113-
headers: Optional[Mapping[str, str]] = ...,
112+
params: Optional[MutableMapping[str, Any]] = ...,
113+
headers: Optional[MutableMapping[str, str]] = ...,
114114
) -> Any: ...
115115
async def indices(
116116
self,
@@ -135,8 +135,8 @@ class CatClient(NamespacedClient):
135135
request_timeout: Optional[Union[int, float]] = ...,
136136
ignore: Optional[Union[int, Collection[int]]] = ...,
137137
opaque_id: Optional[str] = ...,
138-
params: Optional[Mapping[str, Any]] = ...,
139-
headers: Optional[Mapping[str, str]] = ...,
138+
params: Optional[MutableMapping[str, Any]] = ...,
139+
headers: Optional[MutableMapping[str, str]] = ...,
140140
) -> Any: ...
141141
async def master(
142142
self,
@@ -154,8 +154,8 @@ class CatClient(NamespacedClient):
154154
request_timeout: Optional[Union[int, float]] = ...,
155155
ignore: Optional[Union[int, Collection[int]]] = ...,
156156
opaque_id: Optional[str] = ...,
157-
params: Optional[Mapping[str, Any]] = ...,
158-
headers: Optional[Mapping[str, str]] = ...,
157+
params: Optional[MutableMapping[str, Any]] = ...,
158+
headers: Optional[MutableMapping[str, str]] = ...,
159159
) -> Any: ...
160160
async def nodes(
161161
self,
@@ -175,8 +175,8 @@ class CatClient(NamespacedClient):
175175
request_timeout: Optional[Union[int, float]] = ...,
176176
ignore: Optional[Union[int, Collection[int]]] = ...,
177177
opaque_id: Optional[str] = ...,
178-
params: Optional[Mapping[str, Any]] = ...,
179-
headers: Optional[Mapping[str, str]] = ...,
178+
params: Optional[MutableMapping[str, Any]] = ...,
179+
headers: Optional[MutableMapping[str, str]] = ...,
180180
) -> Any: ...
181181
async def recovery(
182182
self,
@@ -197,8 +197,8 @@ class CatClient(NamespacedClient):
197197
request_timeout: Optional[Union[int, float]] = ...,
198198
ignore: Optional[Union[int, Collection[int]]] = ...,
199199
opaque_id: Optional[str] = ...,
200-
params: Optional[Mapping[str, Any]] = ...,
201-
headers: Optional[Mapping[str, str]] = ...,
200+
params: Optional[MutableMapping[str, Any]] = ...,
201+
headers: Optional[MutableMapping[str, str]] = ...,
202202
) -> Any: ...
203203
async def shards(
204204
self,
@@ -219,8 +219,8 @@ class CatClient(NamespacedClient):
219219
request_timeout: Optional[Union[int, float]] = ...,
220220
ignore: Optional[Union[int, Collection[int]]] = ...,
221221
opaque_id: Optional[str] = ...,
222-
params: Optional[Mapping[str, Any]] = ...,
223-
headers: Optional[Mapping[str, str]] = ...,
222+
params: Optional[MutableMapping[str, Any]] = ...,
223+
headers: Optional[MutableMapping[str, str]] = ...,
224224
) -> Any: ...
225225
async def segments(
226226
self,
@@ -238,8 +238,8 @@ class CatClient(NamespacedClient):
238238
request_timeout: Optional[Union[int, float]] = ...,
239239
ignore: Optional[Union[int, Collection[int]]] = ...,
240240
opaque_id: Optional[str] = ...,
241-
params: Optional[Mapping[str, Any]] = ...,
242-
headers: Optional[Mapping[str, str]] = ...,
241+
params: Optional[MutableMapping[str, Any]] = ...,
242+
headers: Optional[MutableMapping[str, str]] = ...,
243243
) -> Any: ...
244244
async def pending_tasks(
245245
self,
@@ -258,8 +258,8 @@ class CatClient(NamespacedClient):
258258
request_timeout: Optional[Union[int, float]] = ...,
259259
ignore: Optional[Union[int, Collection[int]]] = ...,
260260
opaque_id: Optional[str] = ...,
261-
params: Optional[Mapping[str, Any]] = ...,
262-
headers: Optional[Mapping[str, str]] = ...,
261+
params: Optional[MutableMapping[str, Any]] = ...,
262+
headers: Optional[MutableMapping[str, str]] = ...,
263263
) -> Any: ...
264264
async def thread_pool(
265265
self,
@@ -279,8 +279,8 @@ class CatClient(NamespacedClient):
279279
request_timeout: Optional[Union[int, float]] = ...,
280280
ignore: Optional[Union[int, Collection[int]]] = ...,
281281
opaque_id: Optional[str] = ...,
282-
params: Optional[Mapping[str, Any]] = ...,
283-
headers: Optional[Mapping[str, str]] = ...,
282+
params: Optional[MutableMapping[str, Any]] = ...,
283+
headers: Optional[MutableMapping[str, str]] = ...,
284284
) -> Any: ...
285285
async def fielddata(
286286
self,
@@ -298,8 +298,8 @@ class CatClient(NamespacedClient):
298298
request_timeout: Optional[Union[int, float]] = ...,
299299
ignore: Optional[Union[int, Collection[int]]] = ...,
300300
opaque_id: Optional[str] = ...,
301-
params: Optional[Mapping[str, Any]] = ...,
302-
headers: Optional[Mapping[str, str]] = ...,
301+
params: Optional[MutableMapping[str, Any]] = ...,
302+
headers: Optional[MutableMapping[str, str]] = ...,
303303
) -> Any: ...
304304
async def plugins(
305305
self,
@@ -317,8 +317,8 @@ class CatClient(NamespacedClient):
317317
request_timeout: Optional[Union[int, float]] = ...,
318318
ignore: Optional[Union[int, Collection[int]]] = ...,
319319
opaque_id: Optional[str] = ...,
320-
params: Optional[Mapping[str, Any]] = ...,
321-
headers: Optional[Mapping[str, str]] = ...,
320+
params: Optional[MutableMapping[str, Any]] = ...,
321+
headers: Optional[MutableMapping[str, str]] = ...,
322322
) -> Any: ...
323323
async def nodeattrs(
324324
self,
@@ -336,8 +336,8 @@ class CatClient(NamespacedClient):
336336
request_timeout: Optional[Union[int, float]] = ...,
337337
ignore: Optional[Union[int, Collection[int]]] = ...,
338338
opaque_id: Optional[str] = ...,
339-
params: Optional[Mapping[str, Any]] = ...,
340-
headers: Optional[Mapping[str, str]] = ...,
339+
params: Optional[MutableMapping[str, Any]] = ...,
340+
headers: Optional[MutableMapping[str, str]] = ...,
341341
) -> Any: ...
342342
async def repositories(
343343
self,
@@ -355,8 +355,8 @@ class CatClient(NamespacedClient):
355355
request_timeout: Optional[Union[int, float]] = ...,
356356
ignore: Optional[Union[int, Collection[int]]] = ...,
357357
opaque_id: Optional[str] = ...,
358-
params: Optional[Mapping[str, Any]] = ...,
359-
headers: Optional[Mapping[str, str]] = ...,
358+
params: Optional[MutableMapping[str, Any]] = ...,
359+
headers: Optional[MutableMapping[str, str]] = ...,
360360
) -> Any: ...
361361
async def snapshots(
362362
self,
@@ -376,8 +376,8 @@ class CatClient(NamespacedClient):
376376
request_timeout: Optional[Union[int, float]] = ...,
377377
ignore: Optional[Union[int, Collection[int]]] = ...,
378378
opaque_id: Optional[str] = ...,
379-
params: Optional[Mapping[str, Any]] = ...,
380-
headers: Optional[Mapping[str, str]] = ...,
379+
params: Optional[MutableMapping[str, Any]] = ...,
380+
headers: Optional[MutableMapping[str, str]] = ...,
381381
) -> Any: ...
382382
async def tasks(
383383
self,
@@ -398,8 +398,8 @@ class CatClient(NamespacedClient):
398398
request_timeout: Optional[Union[int, float]] = ...,
399399
ignore: Optional[Union[int, Collection[int]]] = ...,
400400
opaque_id: Optional[str] = ...,
401-
params: Optional[Mapping[str, Any]] = ...,
402-
headers: Optional[Mapping[str, str]] = ...,
401+
params: Optional[MutableMapping[str, Any]] = ...,
402+
headers: Optional[MutableMapping[str, str]] = ...,
403403
) -> Any: ...
404404
async def templates(
405405
self,
@@ -418,8 +418,8 @@ class CatClient(NamespacedClient):
418418
request_timeout: Optional[Union[int, float]] = ...,
419419
ignore: Optional[Union[int, Collection[int]]] = ...,
420420
opaque_id: Optional[str] = ...,
421-
params: Optional[Mapping[str, Any]] = ...,
422-
headers: Optional[Mapping[str, str]] = ...,
421+
params: Optional[MutableMapping[str, Any]] = ...,
422+
headers: Optional[MutableMapping[str, str]] = ...,
423423
) -> Any: ...
424424
async def ml_data_frame_analytics(
425425
self,
@@ -439,8 +439,8 @@ class CatClient(NamespacedClient):
439439
request_timeout: Optional[Union[int, float]] = ...,
440440
ignore: Optional[Union[int, Collection[int]]] = ...,
441441
opaque_id: Optional[str] = ...,
442-
params: Optional[Mapping[str, Any]] = ...,
443-
headers: Optional[Mapping[str, str]] = ...,
442+
params: Optional[MutableMapping[str, Any]] = ...,
443+
headers: Optional[MutableMapping[str, str]] = ...,
444444
) -> Any: ...
445445
async def ml_datafeeds(
446446
self,
@@ -460,8 +460,8 @@ class CatClient(NamespacedClient):
460460
request_timeout: Optional[Union[int, float]] = ...,
461461
ignore: Optional[Union[int, Collection[int]]] = ...,
462462
opaque_id: Optional[str] = ...,
463-
params: Optional[Mapping[str, Any]] = ...,
464-
headers: Optional[Mapping[str, str]] = ...,
463+
params: Optional[MutableMapping[str, Any]] = ...,
464+
headers: Optional[MutableMapping[str, str]] = ...,
465465
) -> Any: ...
466466
async def ml_jobs(
467467
self,
@@ -482,8 +482,8 @@ class CatClient(NamespacedClient):
482482
request_timeout: Optional[Union[int, float]] = ...,
483483
ignore: Optional[Union[int, Collection[int]]] = ...,
484484
opaque_id: Optional[str] = ...,
485-
params: Optional[Mapping[str, Any]] = ...,
486-
headers: Optional[Mapping[str, str]] = ...,
485+
params: Optional[MutableMapping[str, Any]] = ...,
486+
headers: Optional[MutableMapping[str, str]] = ...,
487487
) -> Any: ...
488488
async def ml_trained_models(
489489
self,
@@ -505,8 +505,8 @@ class CatClient(NamespacedClient):
505505
request_timeout: Optional[Union[int, float]] = ...,
506506
ignore: Optional[Union[int, Collection[int]]] = ...,
507507
opaque_id: Optional[str] = ...,
508-
params: Optional[Mapping[str, Any]] = ...,
509-
headers: Optional[Mapping[str, str]] = ...,
508+
params: Optional[MutableMapping[str, Any]] = ...,
509+
headers: Optional[MutableMapping[str, str]] = ...,
510510
) -> Any: ...
511511
async def transforms(
512512
self,
@@ -527,6 +527,6 @@ class CatClient(NamespacedClient):
527527
request_timeout: Optional[Union[int, float]] = ...,
528528
ignore: Optional[Union[int, Collection[int]]] = ...,
529529
opaque_id: Optional[str] = ...,
530-
params: Optional[Mapping[str, Any]] = ...,
531-
headers: Optional[Mapping[str, str]] = ...,
530+
params: Optional[MutableMapping[str, Any]] = ...,
531+
headers: Optional[MutableMapping[str, str]] = ...,
532532
) -> Any: ...

0 commit comments

Comments
 (0)