diff --git a/airbyte/shared/catalog_providers.py b/airbyte/shared/catalog_providers.py
index bf22a76b..0da74839 100644
--- a/airbyte/shared/catalog_providers.py
+++ b/airbyte/shared/catalog_providers.py
@@ -155,11 +155,11 @@ def get_primary_keys(
         ]
 
         for pk_nodes in normalized_pks:
-            if len(pk_nodes) != 1:
+            if any("." in node for node in pk_nodes):
                 raise exc.AirbyteError(
                     message=(
                         "Nested primary keys are not supported. "
-                        "Each PK column should have exactly one node. "
+                        "Primary key columns should reference top-level fields only. "
                     ),
                     context={
                         "stream_name": stream_name,