diff --git a/data-egress.tf b/data-egress.tf
index 9e70103..e52c1cc 100644
--- a/data-egress.tf
+++ b/data-egress.tf
@@ -1380,13 +1380,34 @@ resource "aws_dynamodb_table_item" "ap_ml_preprocessed_data" {
 
   item = <<ITEM
   {
-    "source_prefix":                {"S":    "preprocessed_csv/journal/$TODAYS_DATE/*"},
+    "source_prefix":                {"S":    "ap_ml/journal/preprocessed_data/$TODAYS_DATE/*"},
     "pipeline_name":                {"S":    "ap_preproc_journal"},
     "recipient_name":               {"S":    "ap_preproc_journal"},
     "transfer_type":                {"S":    "S3"},
     "source_bucket":                {"S":    "${data.terraform_remote_state.common.outputs.published_bucket.id}"},
     "destination_bucket":           {"S":    "${data.terraform_remote_state.common.outputs.dataworks_model_published_bucket.id}"},
-    "destination_prefix":           {"S":    "/preprocessed/journal/$TODAYS_DATE/"},
+    "destination_prefix":           {"S":    "ap_ml/journal/preprocessed_data/$TODAYS_DATE/"},
+    "decrypt":                      {"bool": true},
+    "rewrap_datakey":               {"bool": false},
+    "encrypting_key_ssm_parm_name": {"S":    ""}
+  }
+  ITEM
+}
+
+resource "aws_dynamodb_table_item" "ap_ml_preprocessed_training_data" {
+  table_name = aws_dynamodb_table.data_egress.name
+  hash_key   = aws_dynamodb_table.data_egress.hash_key
+  range_key  = aws_dynamodb_table.data_egress.range_key
+
+  item = <<ITEM
+  {
+    "source_prefix":                {"S":    "ap_ml/journal/preprocessed_training_data/$TODAYS_DATE/*"},
+    "pipeline_name":                {"S":    "ap_preproc_journal"},
+    "recipient_name":               {"S":    "ap_preproc_journal_training"},
+    "transfer_type":                {"S":    "S3"},
+    "source_bucket":                {"S":    "${data.terraform_remote_state.common.outputs.published_bucket.id}"},
+    "destination_bucket":           {"S":    "${data.terraform_remote_state.common.outputs.dataworks_model_published_bucket.id}"},
+    "destination_prefix":           {"S":    "ap_ml/journal/preprocessed_training_data/$TODAYS_DATE/"},
     "decrypt":                      {"bool": true},
     "rewrap_datakey":               {"bool": false},
     "encrypting_key_ssm_parm_name": {"S":    ""}
diff --git a/data-egress_iam.tf b/data-egress_iam.tf
index e41b121..a526a52 100644
--- a/data-egress_iam.tf
+++ b/data-egress_iam.tf
@@ -141,7 +141,7 @@ data "aws_iam_policy_document" "data_egress_server_task" {
       "${data.terraform_remote_state.common.outputs.published_bucket.arn}/dataegress/best-start/*",
       "${data.terraform_remote_state.common.outputs.published_bucket.arn}/dataegress/ers/*",
       "${data.terraform_remote_state.common.outputs.published_bucket.arn}/dataegress/RIS_DSP_Manual/*",
-      "${data.terraform_remote_state.common.outputs.published_bucket.arn}/preprocessed_csv/*"
+      "${data.terraform_remote_state.common.outputs.published_bucket.arn}/ap_ml/*"
     ]
   }