diff --git a/src/backend/distributed/commands/extension.c b/src/backend/distributed/commands/extension.c index 34ff7c995..e7be51992 100644 --- a/src/backend/distributed/commands/extension.c +++ b/src/backend/distributed/commands/extension.c @@ -512,7 +512,7 @@ MarkExistingObjectDependenciesDistributedIfSupported() Oid citusTableId = InvalidOid; foreach_oid(citusTableId, citusTableIdList) { - if (!ShouldMarkRelationDistributedOnUpgrade(citusTableId)) + if (!ShouldMarkRelationDistributed(citusTableId)) { continue; } @@ -556,7 +556,7 @@ MarkExistingObjectDependenciesDistributedIfSupported() Oid viewOid = InvalidOid; foreach_oid(viewOid, viewList) { - if (!ShouldMarkRelationDistributedOnUpgrade(viewOid)) + if (!ShouldMarkRelationDistributed(viewOid)) { continue; } @@ -654,12 +654,12 @@ GetAllViews(void) /* - * ShouldMarkRelationDistributedOnUpgrade is a helper function that + * ShouldMarkRelationDistributed is a helper function that * decides whether the input relation should be marked as distributed * during the upgrade. */ bool -ShouldMarkRelationDistributedOnUpgrade(Oid relationId) +ShouldMarkRelationDistributed(Oid relationId) { if (!EnableMetadataSync) { diff --git a/src/backend/distributed/metadata/metadata_sync.c b/src/backend/distributed/metadata/metadata_sync.c index a81ef9ec3..f5e99ce8a 100644 --- a/src/backend/distributed/metadata/metadata_sync.c +++ b/src/backend/distributed/metadata/metadata_sync.c @@ -337,7 +337,7 @@ CreateDependentViewsOnWorkers(Oid relationId) Oid viewOid = InvalidOid; foreach_oid(viewOid, views) { - if (!ShouldMarkRelationDistributedOnUpgrade(viewOid)) + if (!ShouldMarkRelationDistributed(viewOid)) { continue; } diff --git a/src/include/distributed/commands.h b/src/include/distributed/commands.h index c6e3f8aeb..483c279d5 100644 --- a/src/include/distributed/commands.h +++ b/src/include/distributed/commands.h @@ -181,7 +181,7 @@ extern Oid get_constraint_typid(Oid conoid); /* extension.c - forward declarations */ extern bool IsDropCitusExtensionStmt(Node *parsetree); extern bool IsCreateAlterExtensionUpdateCitusStmt(Node *parsetree); -extern bool ShouldMarkRelationDistributedOnUpgrade(Oid relationId); +extern bool ShouldMarkRelationDistributed(Oid relationId); extern void ErrorIfUnstableCreateOrAlterExtensionStmt(Node *parsetree); extern List * PostprocessCreateExtensionStmt(Node *stmt, const char *queryString); extern List * PreprocessDropExtensionStmt(Node *stmt, const char *queryString,