diff --git a/src/pg/test/sql/41_observatory_augmentation_test.sql b/src/pg/test/sql/41_observatory_augmentation_test.sql
index e5081a2..692967e 100644
--- a/src/pg/test/sql/41_observatory_augmentation_test.sql
+++ b/src/pg/test/sql/41_observatory_augmentation_test.sql
@@ -1,7 +1,7 @@
 \i test/sql/load_fixtures.sql
 --
 WITH result as(
-  Select count(OBS_GetDemographicSnapshot->>'value') expected_columns
+  Select count(cdb_observatory.OBS_GetDemographicSnapshot->>'value') expected_columns
   FROM cdb_observatory.OBS_GetDemographicSnapshot(cdb_observatory._TestPoint())
 ) select expected_columns ='58' as OBS_GetDemographicSnapshot_test_no_returns
 FROM result;