mirror of
https://github.com/open-metadata/OpenMetadata
synced 2026-05-24 09:39:11 +00:00
09af9fc801
* fix(restore): bulk + async restore for large entity hierarchies EntityRepository.restoreEntity walked descendants synchronously, taking 4+ minutes on a 12k-table database and exceeding typical proxy timeouts. restoreChildren now groups CONTAINS children by type and dispatches one bulkRestoreSubtree per type, batching DB writes, version history, change events, and cache invalidation; the existing ES cascade handles descendant index updates in one update_by_query. Adds an async option (?async=true) on the deep-hierarchy restore endpoints that returns 202 Accepted with a job id and runs the restore on AsyncService, emitting WebSocket notifications on restoreEntityChannel. Java SDK adds .restore().async().execute() fluent builders on Tables/Databases plus restoreServerAsync on EntityServiceBase; Python SDK mirrors this with restore_request().with_async().execute() and restore_async() helpers on BaseEntity, exposing a new AsyncJobResponse type. Tests: EntityRepositoryRestoreTest verifies the per-type grouping and bulk dispatch path; RestoreFluentAPITest covers the Java SDK fluent behavior; RestoreHierarchyIT exercises sync and async restore against a real DB→schemas→tables tree end-to-end; test_restore_async.py covers the Python SDK paths. Fixes #4003 |
||
|---|---|---|
| .. | ||
| airflow | ||
| alationsink | ||
| amundsen | ||
| atlas | ||
| auto_classification | ||
| automations | ||
| cassandra | ||
| cockroach | ||
| connections | ||
| data_quality | ||
| datalake | ||
| fivetran | ||
| great_expectations | ||
| kafka | ||
| lineage | ||
| mcp | ||
| mongodb | ||
| mysql | ||
| ometa | ||
| orm_profiler | ||
| postgres | ||
| powerbi | ||
| profiler | ||
| s3 | ||
| sas | ||
| sdk | ||
| sftp | ||
| sources | ||
| sql_server | ||
| ssrs | ||
| superset | ||
| test_suite | ||
| trino | ||
| usage | ||
| workflow | ||
| __init__.py | ||
| conftest.py | ||
| containers.py | ||
| integration_base.py | ||