Skip to content

Commit faa768f

Browse files
authored
MINOR: Fix incremental lineage if processedLineage is null (#20219)
1 parent 2247b0a commit faa768f

File tree

1 file changed

+14
-1
lines changed
  • ingestion/src/metadata/ingestion/ometa/mixins

1 file changed

+14
-1
lines changed

ingestion/src/metadata/ingestion/ometa/mixins/es_mixin.py

+14-1
Original file line numberDiff line numberDiff line change
@@ -464,7 +464,20 @@ def yield_es_view_def(
464464
}
465465
if incremental:
466466
query.get("query").get("bool").get("must").append(
467-
{"bool": {"should": [{"term": {"processedLineage": False}}]}}
467+
{
468+
"bool": {
469+
"should": [
470+
{"term": {"processedLineage": False}},
471+
{
472+
"bool": {
473+
"must_not": {
474+
"exists": {"field": "processedLineage"}
475+
}
476+
}
477+
},
478+
]
479+
}
480+
}
468481
)
469482
query = json.dumps(query)
470483
for response in self._paginate_es_internal(

0 commit comments

Comments
 (0)