upgrade test

onder_view_2
Onder Kalaci 2022-04-25 17:00:08 +02:00
parent ff003bccd8
commit 7419f031d7
1 changed files with 14 additions and 0 deletions

View File

@ -521,6 +521,20 @@ MarkExistingObjectDependenciesDistributedIfSupported()
/* as of Citus 11, tables that should be synced are also considered object */
resultingObjectAddresses = lappend(resultingObjectAddresses, addressPointer);
List *viewList = GetDependingViews(citusTableId);
Oid viewOid = InvalidOid;
foreach_oid(viewOid, viewList)
{
ObjectAddress viewAddress = { 0 };
ObjectAddressSet(viewAddress, RelationRelationId, viewOid);
if (DeferErrorIfHasUnsupportedDependency(viewAddress) == NULL)
{
/* as of Citus 11, tables that should be synced are also considered object */
resultingObjectAddresses = lappend(resultingObjectAddresses, addressPointer);
}
}
}
List *distributableDependencyObjectAddresses =