in elasticsearch/dsl/_sync/document.py [0:0]
def __next__(self) -> Dict[str, Any]:
doc: Optional[Union[Document, Dict[str, Any]]] = (
self.doc_iterator.__next__()
)
if isinstance(doc, dict):
action = doc
doc = None
if "_source" in action and isinstance(action["_source"], Document):
doc = action["_source"]
if validate: # pragma: no cover
doc.full_clean()
action["_source"] = doc.to_dict(
include_meta=False, skip_empty=skip_empty
)
elif doc is not None:
if validate: # pragma: no cover
doc.full_clean()
action = doc.to_dict(include_meta=True, skip_empty=skip_empty)
if "_index" not in action:
action["_index"] = i
return action