7d9a7fead18653a43645c3d673499cf639337406,lambdas/es/indexer/document_queue.py,DocumentQueue,send_all,#DocumentQueue#,127

Before Change

                    info = inner.get("error")
                    doc = id_to_doc[inner["_id"]]
                    // because error.error might be a string *sigh*
                    if isinstance(info, dict):
                        if "mapper_parsing_exception" in info.get("type", ""):
                            print("mapper_parsing_exception", error, inner)
                            // clear out structured metadata and try again
                            doc["user_meta"] = doc["system"] = {}
                        else:
                            print("unhandled indexer error:", error)
                    // Always retry, regardless of whether we know to handle and clean the request
                    // or not. This can catch temporary 403 on index write blocks and other
                    // transient issues.
                    send_again.append(doc)
                else:
                    // If index not in error, then retry the whole batch. Unclear what would cause
                    // that, but if there"s an error without an id we need to assume it applies to

After Change

                if "index" in error or "delete" in error:
                    if "index" in error:
                        inner = error["index"]
                    if "delete" in error:
                        inner = error["delete"]
                    if "_id" in inner:
                        doc = id_to_doc[inner["_id"]]
                        // Always retry the source document if we can identify it.
                        // This catches temporary 403 on index write blocks & other

Instances