diff --git a/metadata-ingestion/src/datahub/cli/cli_utils.py b/metadata-ingestion/src/datahub/cli/cli_utils.py index a9cccb8d06..9ef44f85d8 100644 --- a/metadata-ingestion/src/datahub/cli/cli_utils.py +++ b/metadata-ingestion/src/datahub/cli/cli_utils.py @@ -315,6 +315,7 @@ def get_urns_by_filter( and entity_type == "dataset" or entity_type == "dataflow" or entity_type == "datajob" + or entity_type == "container" ): filter_criteria.append( { diff --git a/metadata-ingestion/src/datahub/cli/delete_cli.py b/metadata-ingestion/src/datahub/cli/delete_cli.py index 86c3869eb2..33dc18c523 100644 --- a/metadata-ingestion/src/datahub/cli/delete_cli.py +++ b/metadata-ingestion/src/datahub/cli/delete_cli.py @@ -228,6 +228,7 @@ def delete_with_filters( one_result = _delete_one_urn( urn, soft=soft, + entity_type=entity_type, dry_run=dry_run, cached_session_host=(session, gms_host), cached_emitter=emitter,