diff --git a/ingestion/src/metadata/ingestion/api/topology_runner.py b/ingestion/src/metadata/ingestion/api/topology_runner.py
index b50bdb972ad..2374b359283 100644
--- a/ingestion/src/metadata/ingestion/api/topology_runner.py
+++ b/ingestion/src/metadata/ingestion/api/topology_runner.py
@@ -376,7 +376,11 @@ class TopologyRunnerMixin(Generic[C]):
             entity_source_hash = self.cache[stage.type_].get(entity_fqn)
             if entity_source_hash:
                 # if the source hash is present, compare it with new hash
-                if entity_source_hash != create_entity_request_hash:
+                # if overrideMetadata is true, we will always update the entity
+                if (
+                    entity_source_hash != create_entity_request_hash
+                    or self.source_config.overrideMetadata
+                ):
                     # the entity has changed, get the entity from server and make a patch request
                     entity = self.metadata.get_by_name(
                         entity=stage.type_,