Skip to content

Commit

Permalink
feat: return a empty dict when get_last_indexed returns nothing
Browse files Browse the repository at this point in the history
  • Loading branch information
helllllllder committed May 24, 2024
1 parent fca619a commit ad420d5
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion flowrun/storage/elasticsearch.py
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ def get_last_indexed(self, org):
)["hits"]["hits"][0]["_source"]
except (AttributeError, TypeError, IndexError) as err:
print("[-] <Warning> Elasticsearch Get error: ", type(err), err)
return None
return {}
return es_flow_run

def get_last_indexed_timestamp(self, org):
Expand Down

0 comments on commit ad420d5

Please sign in to comment.