diff --git a/x-pack/plugins/ingest_manager/server/services/epm/packages/assets.test.ts b/x-pack/plugins/ingest_manager/server/services/epm/packages/assets.test.ts
index 776d4e7229a16..eb43bef72db70 100644
--- a/x-pack/plugins/ingest_manager/server/services/epm/packages/assets.test.ts
+++ b/x-pack/plugins/ingest_manager/server/services/epm/packages/assets.test.ts
@@ -31,8 +31,8 @@ const tests = [
       return true;
     },
     expected: [
-      'coredns-1.0.1/dataset/log/elasticsearch/ingest-pipeline/pipeline-plaintext.json',
-      'coredns-1.0.1/dataset/log/elasticsearch/ingest-pipeline/pipeline-json.json',
+      'coredns-1.0.1/data_stream/log/elasticsearch/ingest-pipeline/pipeline-plaintext.json',
+      'coredns-1.0.1/data_stream/log/elasticsearch/ingest-pipeline/pipeline-json.json',
     ],
   },
   {
@@ -60,7 +60,7 @@ const tests = [
   },
 ];
 
-test.skip('testGetAssets', () => {
+test('testGetAssets', () => {
   for (const value of tests) {
     // as needed to pretend it is an InstallablePackage
     const assets = getAssets(value.package as InstallablePackage, value.filter, value.dataset);
diff --git a/x-pack/plugins/ingest_manager/server/services/epm/packages/assets.ts b/x-pack/plugins/ingest_manager/server/services/epm/packages/assets.ts
index 3c5b008277e5d..856f04c0c9b67 100644
--- a/x-pack/plugins/ingest_manager/server/services/epm/packages/assets.ts
+++ b/x-pack/plugins/ingest_manager/server/services/epm/packages/assets.ts
@@ -33,7 +33,7 @@ export function getAssets(
 
     // if dataset, filter for them
     if (datasetName) {
-      const comparePath = `${packageInfo.name}-${packageInfo.version}/datastream/${datasetName}/`;
+      const comparePath = `${packageInfo.name}-${packageInfo.version}/data_stream/${datasetName}/`;
       if (!path.includes(comparePath)) {
         continue;
       }