diff --git a/src/org/ohdsi/rabbitInAHat/ETLPackageTestFrameWorkGenerator.java b/src/org/ohdsi/rabbitInAHat/ETLPackageTestFrameWorkGenerator.java
index b7b1c9b0..7be5284a 100644
--- a/src/org/ohdsi/rabbitInAHat/ETLPackageTestFrameWorkGenerator.java
+++ b/src/org/ohdsi/rabbitInAHat/ETLPackageTestFrameWorkGenerator.java
@@ -244,7 +244,7 @@ private static void createInitFunction(List<String> r, Database database) {
 	  r.add("  insertSql <- c()");
 		for (Table table : database.getTables()) {
 			String sqlTableName = convertToSqlName(table.getName());
-			r.add("  insertSql <- c(insertSql, \"TRUNCATE TABLE @cdm_schema." + sqlTableName + ";\")");
+			r.add("  insertSql <- c(insertSql, \"TRUNCATE TABLE @source_schema." + sqlTableName + ";\")");
 		}
 		r.add("  frameworkContext$insertSql <- insertSql;");