actions/opensearch-pyd
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Support both deprecated and new bulk parameters

Browse Source 
Fixes #1020
This commit is contained in:
Thomas Thiebaud
2019-11-21 17:41:21 +01:00
parent 07fef33acc
commit 321561f4c3
1 changed files with 17 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
elasticsearch/helpers/actions.py
+17 -7
View File
@@ -27,22 +27,26 @@ def expand_action(data):
op_type = data.pop("_op_type", "index")
action = {op_type: {}}
for key in (
"_id",
"_index",
"_parent",
"_percolate",
"_retry_on_conflict",
"_routing",
"_timestamp",
"routing",
"_type",
"_version",
"_version_type",
"_id",
"retry_on_conflict",
"parent",
"pipeline",
"retry_on_conflict",
"routing",
"version",
"version_type",
):
if key in data:
if key == "_routing":
action[op_type]["routing"] = data.pop(key)
if key in ["_parent", "_retry_on_conflict", "_routing", "_version", "_version_type"]:
action[op_type][key[1:]] = data.pop(key)
else:
action[op_type][key] = data.pop(key)
@@ -442,7 +446,9 @@ def scan(
yield hit
# check if we have any errors
if (resp["_shards"]["successful"] + resp["_shards"]["skipped"]) < resp["_shards"]["total"]:
if (resp["_shards"]["successful"] + resp["_shards"]["skipped"]) < resp[
"_shards"
]["total"]:
logger.warning(
"Scroll request has only succeeded on %d (+%d skipped) shards out of %d.",
resp["_shards"]["successful"],
@@ -453,7 +459,11 @@ def scan(
raise ScanError(
scroll_id,
"Scroll request has only succeeded on %d (+%d skiped) shards out of %d."
% (resp["_shards"]["successful"], resp["_shards"]["skipped"], resp["_shards"]["total"]),
% (
resp["_shards"]["successful"],
resp["_shards"]["skipped"],
resp["_shards"]["total"],
),
)
resp = client.scroll(
body={"scroll_id": scroll_id, "scroll": scroll}, **scroll_kwargs