diff --git a/src/backend/distributed/utils/metadata_cache.c b/src/backend/distributed/utils/metadata_cache.c index 441c9464e..1e8c3253f 100644 --- a/src/backend/distributed/utils/metadata_cache.c +++ b/src/backend/distributed/utils/metadata_cache.c @@ -223,7 +223,6 @@ static void CachedRelationNamespaceLookup(const char *relationName, Oid relnames Oid *cachedOid); static ShardPlacement * ResolveGroupShardPlacement( GroupShardPlacement *groupShardPlacement, ShardCacheEntry *shardEntry); -static WorkerNode * LookupNodeForGroup(int32 groupId); static Oid LookupEnumValueId(Oid typeId, char *valueName); static void InvalidateEntireDistCache(void); @@ -596,7 +595,7 @@ LookupNodeByNodeId(uint32 nodeId) * if we're reading from secondaries). If such a node does not exist it emits an * appropriate error message. */ -static WorkerNode * +WorkerNode * LookupNodeForGroup(int32 groupId) { bool foundAnyNodes = false; diff --git a/src/include/distributed/metadata_cache.h b/src/include/distributed/metadata_cache.h index 29374068d..5b0b47400 100644 --- a/src/include/distributed/metadata_cache.h +++ b/src/include/distributed/metadata_cache.h @@ -122,6 +122,7 @@ extern void EnsureModificationsCanRun(void); /* access WorkerNodeHash */ extern HTAB * GetWorkerNodeHash(void); extern WorkerNode * LookupNodeByNodeId(uint32 nodeId); +extern WorkerNode * LookupNodeForGroup(int32 groupId); /* namespace oids */ extern Oid CitusCatalogNamespaceId(void);