diff --git a/views/ndt_intermediate/extended_ndt5_downloads.sql b/views/ndt_intermediate/extended_ndt5_downloads.sql
index ac84f5e..c11c9c8 100644
--- a/views/ndt_intermediate/extended_ndt5_downloads.sql
+++ b/views/ndt_intermediate/extended_ndt5_downloads.sql
@@ -12,7 +12,7 @@ WITH ndt5downloads AS (
   SELECT partition_date, ParseInfo, result.S2C,
   (result.S2C.Error != "") AS IsErrored,
   TIMESTAMP_DIFF(result.S2C.EndTime, result.S2C.StartTime, MICROSECOND) AS connection_duration
-  FROM   `{{.ProjectID}}.ndt.ndt5` -- TODO move to intermediate_ndt
+  FROM   `{{.ProjectID}}.ndt_raw.ndt5_legacy` -- TODO move to intermediate_ndt
   -- Limit to valid S2C results
   WHERE result.S2C IS NOT NULL
   AND result.S2C.UUID IS NOT NULL
diff --git a/views/ndt_intermediate/extended_ndt5_uploads.sql b/views/ndt_intermediate/extended_ndt5_uploads.sql
index 308aeeb..cd13792 100644
--- a/views/ndt_intermediate/extended_ndt5_uploads.sql
+++ b/views/ndt_intermediate/extended_ndt5_uploads.sql
@@ -12,7 +12,7 @@ WITH ndt5uploads AS (
   SELECT partition_date, ParseInfo, result.C2S,
   (result.C2S.Error != "") AS IsErrored,
   TIMESTAMP_DIFF(result.C2S.EndTime, result.C2S.StartTime, MICROSECOND) AS connection_duration
-  FROM   `{{.ProjectID}}.ndt.ndt5` -- TODO move to intermediate_ndt
+  FROM   `{{.ProjectID}}.ndt_raw.ndt5_legacy` -- TODO move to intermediate_ndt
   -- Limit to valid C2S results
   WHERE  result.C2S IS NOT NULL
   AND result.C2S.UUID NOT IN ( '', 'ERROR_DISCOVERING_UUID' )