Skip to content

Commit ddac2af

Browse files
authored
Revert "Added a method to backfill shadow relationship tables (#546)" (#565)
This reverts commit 2dbbf51.
1 parent 7e1a847 commit ddac2af

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

restli-resources/src/main/java/com/linkedin/metadata/restli/BaseEntityResource.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -818,17 +818,13 @@ public Task<BackfillResult> backfillRelationshipTables(@ActionParam(PARAM_URNS)
818818

819819
private Task<BackfillResult> backfillRelationshipTables(@ActionParam(PARAM_URNS) @Nonnull String[] urns,
820820
@ActionParam(PARAM_ASPECTS) @Nonnull String[] aspectNames, boolean isInternalModelsEnabled) {
821-
822-
// Use the shadow DAO if it exists, otherwise use the local DAO. It's a temporary solution for EGG migration.
823-
BaseLocalDAO<INTERNAL_ASPECT_UNION, URN> dao = getShadowLocalDAO() != null ? getShadowLocalDAO() : getLocalDAO();
824-
825821
final BackfillResult backfillResult = new BackfillResult()
826822
.setEntities(new BackfillResultEntityArray())
827823
.setRelationships(new BackfillResultRelationshipArray());
828824

829825
for (String urn : urns) {
830826
for (Class<? extends RecordTemplate> aspect : parseAspectsParam(aspectNames, isInternalModelsEnabled)) {
831-
dao.backfillLocalRelationships(parseUrnParam(urn), aspect).forEach(relationshipUpdates -> {
827+
getLocalDAO().backfillLocalRelationships(parseUrnParam(urn), aspect).forEach(relationshipUpdates -> {
832828
relationshipUpdates.getRelationships().forEach(relationship -> {
833829
try {
834830
Urn source = (Urn) relationship.getClass().getMethod("getSource").invoke(relationship);

0 commit comments

Comments
 (0)