Add aspect type filter to metadata sync

acryldata · Oct 29, 2024 · 98ad801 · 98ad801
1 parent cf62ef5
commit 98ad801
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/...ub-actions/src/datahub_actions/plugin/action/metadata_change_sync/metadata_change_sync.py b/...ub-actions/src/datahub_actions/plugin/action/metadata_change_sync/metadata_change_sync.py
@@ -23,7 +23,6 @@ class MetadataChangeEmitterConfig(BaseModel):
     aspects_to_exclude: Optional[List]
     entity_type_to_exclude: Optional[List] = Field(default_factory=list)
     extra_headers: Optional[Dict[str, str]]
-    enable_soft_delete_filter: Optional[bool] = True
 
 
 class MetadataChangeSyncAction(Action):
@@ -80,10 +79,8 @@ def act(self, event: EventEnvelope) -> None:
         if event.event_type is METADATA_CHANGE_LOG_EVENT_V1_TYPE:
             orig_event = cast(MetadataChangeLogClass, event.event)
             logger.debug(f"received orig_event {orig_event}")
-            if (
-                orig_event.get("aspectName") not in self.aspects_exclude_set
-                and orig_event.get("entityType")
-                not in self.config.entity_type_to_exclude
+            if (orig_event.get("aspectName") not in self.aspects_exclude_set) and (
+                orig_event.get("entityType") not in self.config.entity_type_to_exclude
             ):
                 mcp = self.buildMcp(orig_event)
                 if mcp is not None: