upgrade test

onder_view_2
Onder Kalaci 2022-04-25 17:10:39 +02:00
parent 6d2d70b754
commit 7d57c7e1f9
1 changed files with 7 additions and 2 deletions

View File

@ -523,17 +523,22 @@ MarkExistingObjectDependenciesDistributedIfSupported()
resultingObjectAddresses = lappend(resultingObjectAddresses, addressPointer);
List *viewList = GetDependingViews(citusTableId);
elog(WARNING, "size: %d", list_length(viewList));
Oid viewOid = InvalidOid;
foreach_oid(viewOid, viewList)
{
ObjectAddress viewAddress = { 0 };
ObjectAddressSet(viewAddress, RelationRelationId, viewOid);
if (DeferErrorIfHasUnsupportedDependency(&viewAddress) == NULL)
DeferredErrorMessage *msg = DeferErrorIfHasUnsupportedDependency(&viewAddress);
if (msg == NULL)
{
/* as of Citus 11, tables that should be synced are also considered object */
resultingObjectAddresses = lappend(resultingObjectAddresses, addressPointer);
}
else
RaiseDeferredErrorInternal(msg, WARNING);
}
}