diff --git a/packages/scripts/package.json b/packages/scripts/package.json
index 8f3ee0624b8..20d79fcf8bc 100644
--- a/packages/scripts/package.json
+++ b/packages/scripts/package.json
@@ -1,7 +1,7 @@
 {
     "name": "@terascope/scripts",
     "displayName": "Scripts",
-    "version": "1.4.2",
+    "version": "1.5.0",
     "description": "A collection of terascope monorepo scripts",
     "homepage": "https://github.com/terascope/teraslice/tree/master/packages/scripts#readme",
     "bugs": {
diff --git a/packages/scripts/src/cmds/test.ts b/packages/scripts/src/cmds/test.ts
index 227ef5305d9..bb22d88d965 100644
--- a/packages/scripts/src/cmds/test.ts
+++ b/packages/scripts/src/cmds/test.ts
@@ -22,6 +22,7 @@ type Options = {
     packages?: PackageInfo[];
     'ignore-mount': boolean;
     'test-platform': string;
+    'skip-image-deletion': boolean;
 };
 
 const jestArgs = getExtraArgs();
@@ -101,6 +102,11 @@ const cmd: CommandModule<GlobalCMDOptions, Options> = {
                 default: config.TEST_PLATFORM,
                 choices: ['native', 'kubernetes', 'kubernetesV2']
             })
+            .option('skip-image-deletion', {
+                description: 'Skip the deletion of docker images from cache after loading into docker.\n This is useful if a CI job calls `ts-scripts test` more than once.',
+                type: 'boolean',
+                default: config.SKIP_IMAGE_DELETION,
+            })
             .positional('packages', {
                 description: 'Runs the tests for one or more package and/or an asset, if none specified it will run all of the tests',
                 coerce(arg) {
@@ -126,6 +132,7 @@ const cmd: CommandModule<GlobalCMDOptions, Options> = {
         const ignoreMount = hoistJestArg(argv, 'ignore-mount', 'boolean');
         const testPlatform = hoistJestArg(argv, 'test-platform', 'string') as 'native' | 'kubernetes' | 'kubernetesV2';
         const kindClusterName = testPlatform === 'native' ? 'default' : 'k8s-e2e';
+        const skipImageDeletion = hoistJestArg(argv, 'skip-image-deletion', 'boolean');
 
         if (debug && watch) {
             throw new Error('--debug and --watch conflict, please set one or the other');
@@ -147,6 +154,7 @@ const cmd: CommandModule<GlobalCMDOptions, Options> = {
             ignoreMount,
             testPlatform,
             kindClusterName,
+            skipImageDeletion
         });
     },
 };
diff --git a/packages/scripts/src/helpers/config.ts b/packages/scripts/src/helpers/config.ts
index c4cebedf9f7..a1250e87413 100644
--- a/packages/scripts/src/helpers/config.ts
+++ b/packages/scripts/src/helpers/config.ts
@@ -206,3 +206,4 @@ export const {
 export const DOCKER_IMAGES_PATH = './images';
 export const DOCKER_IMAGE_LIST_PATH = `${DOCKER_IMAGES_PATH}/image-list.txt`;
 export const DOCKER_CACHE_PATH = '/tmp/docker_cache';
+export const SKIP_IMAGE_DELETION = toBoolean(process.env.SKIP_IMAGE_DELETION) || false;
diff --git a/packages/scripts/src/helpers/k8s-env/index.ts b/packages/scripts/src/helpers/k8s-env/index.ts
index af5c95fdbe6..d36b34e8e8e 100644
--- a/packages/scripts/src/helpers/k8s-env/index.ts
+++ b/packages/scripts/src/helpers/k8s-env/index.ts
@@ -106,7 +106,8 @@ export async function launchK8sEnv(options: K8sEnvOptions) {
         reportCoverage: false,
         useExistingServices: false,
         ignoreMount: false,
-        testPlatform: options.clusteringType
+        testPlatform: options.clusteringType,
+        skipImageDeletion: false
     });
 
     try {
diff --git a/packages/scripts/src/helpers/kind.ts b/packages/scripts/src/helpers/kind.ts
index 6f4721b3430..ee790a0fa7e 100644
--- a/packages/scripts/src/helpers/kind.ts
+++ b/packages/scripts/src/helpers/kind.ts
@@ -80,7 +80,7 @@ export class Kind {
 
     // TODO: check that image is loaded before we continue
     async loadServiceImage(
-        serviceName: string, serviceImage: string, version: string
+        serviceName: string, serviceImage: string, version: string, skipDelete: boolean
     ): Promise<void> {
         let subprocess;
         try {
@@ -95,7 +95,9 @@ export class Kind {
                 subprocess = await execaCommand(`gunzip -d ${filePath}`);
                 signale.info(`${subprocess.command}: successful`);
                 subprocess = await execaCommand(`kind load --name ${this.clusterName} image-archive ${tarPath}`);
-                fs.rmSync(tarPath);
+                if (!skipDelete) {
+                    fs.rmSync(tarPath);
+                }
             } else {
                 subprocess = await execaCommand(`kind load --name ${this.clusterName} docker-image ${serviceImage}:${version}`);
             }
diff --git a/packages/scripts/src/helpers/scripts.ts b/packages/scripts/src/helpers/scripts.ts
index fcbe3289496..56dc123de73 100644
--- a/packages/scripts/src/helpers/scripts.ts
+++ b/packages/scripts/src/helpers/scripts.ts
@@ -456,11 +456,15 @@ async function dockerImageRm(image: string): Promise<void> {
 
 /**
  * Unzips and loads a Docker image from a Docker cache
- * If successful the image will be deleted from the cache
+ * If successful and skipDelete is false the image will be deleted from the cache
  * @param {string} imageName Name of the image to load
+ * @param {boolean} skipDelete Skip removal of docker image from cache
  * @returns {Promise<boolean>} Whether or not the image loaded successfully
  */
-export async function loadThenDeleteImageFromCache(imageName: string): Promise<boolean> {
+export async function loadThenDeleteImageFromCache(
+    imageName: string,
+    skipDelete = false
+): Promise<boolean> {
     signale.time(`unzip and load ${imageName}`);
     const fileName = imageName.trim().replace(/[/:]/g, '_');
     const filePath = path.join(config.DOCKER_CACHE_PATH, `${fileName}.tar.gz`);
@@ -478,7 +482,11 @@ export async function loadThenDeleteImageFromCache(imageName: string): Promise<b
         return false;
     }
 
-    fs.rmSync(filePath);
+    if (!skipDelete) {
+        signale.info(`Deleting ${imageName} from docker image cache.`);
+        fs.rmSync(filePath);
+    }
+
     signale.timeEnd(`unzip and load ${imageName}`);
 
     return true;
diff --git a/packages/scripts/src/helpers/test-runner/index.ts b/packages/scripts/src/helpers/test-runner/index.ts
index 1d725c88584..9f871934a07 100644
--- a/packages/scripts/src/helpers/test-runner/index.ts
+++ b/packages/scripts/src/helpers/test-runner/index.ts
@@ -106,7 +106,7 @@ async function runTestSuite(
 
     if (isCI) {
         // load the services from cache in CI
-        await loadOrPullServiceImages(suite);
+        await loadOrPullServiceImages(suite, options.skipImageDeletion);
     }
 
     const CHUNK_SIZE = options.debug ? 1 : MAX_PROJECTS_PER_BATCH;
@@ -219,7 +219,7 @@ async function runE2ETest(
             kind = new Kind(K8S_VERSION, options.kindClusterName);
             try {
                 if (isCI) {
-                    await loadThenDeleteImageFromCache('kindest/node:v1.30.0');
+                    await loadThenDeleteImageFromCache('kindest/node:v1.30.0', options.skipImageDeletion);
                 }
                 await kind.createCluster();
             } catch (err) {
@@ -240,12 +240,11 @@ async function runE2ETest(
     if (isCI) {
         // load service if in native. In k8s services will be loaded directly to kind
         if (options.testPlatform === 'native') {
-            await loadOrPullServiceImages(suite);
-            await deleteDockerImageCache();
+            await loadOrPullServiceImages(suite, options.skipImageDeletion);
         }
 
         // load the base docker image
-        await loadThenDeleteImageFromCache(`${BASE_DOCKER_IMAGE}:${NODE_VERSION}`);
+        await loadThenDeleteImageFromCache(`${BASE_DOCKER_IMAGE}:${NODE_VERSION}`, options.skipImageDeletion);
     }
 
     try {
@@ -283,7 +282,9 @@ async function runE2ETest(
         tracker.addError(err);
     }
 
-    await deleteDockerImageCache();
+    if (!options.skipImageDeletion) {
+        await deleteDockerImageCache();
+    }
 
     if (!tracker.hasErrors()) {
         const timeLabel = `test suite "${suite}"`;
diff --git a/packages/scripts/src/helpers/test-runner/interfaces.ts b/packages/scripts/src/helpers/test-runner/interfaces.ts
index 466836c3471..e886964baf6 100644
--- a/packages/scripts/src/helpers/test-runner/interfaces.ts
+++ b/packages/scripts/src/helpers/test-runner/interfaces.ts
@@ -16,6 +16,7 @@ export type TestOptions = {
     ignoreMount: boolean;
     testPlatform: 'native' | 'kubernetes' | 'kubernetesV2';
     kindClusterName: string;
+    skipImageDeletion: boolean;
 };
 
 export type GroupedPackages = {
diff --git a/packages/scripts/src/helpers/test-runner/services.ts b/packages/scripts/src/helpers/test-runner/services.ts
index 07cf4d6a4a6..99187959e0a 100644
--- a/packages/scripts/src/helpers/test-runner/services.ts
+++ b/packages/scripts/src/helpers/test-runner/services.ts
@@ -160,7 +160,10 @@ const services: Readonly<Record<Service, Readonly<DockerRunOptions>>> = {
     }
 };
 
-export async function loadOrPullServiceImages(suite: string): Promise<void> {
+export async function loadOrPullServiceImages(
+    suite: string,
+    skipImageDeletion: boolean
+): Promise<void> {
     const launchServices = getServicesForSuite(suite);
 
     try {
@@ -209,7 +212,7 @@ export async function loadOrPullServiceImages(suite: string): Promise<void> {
 
         if (fs.existsSync(config.DOCKER_CACHE_PATH)) {
             await Promise.all(images.map(async (imageName) => {
-                const success = await loadThenDeleteImageFromCache(imageName);
+                const success = await loadThenDeleteImageFromCache(imageName, skipImageDeletion);
                 if (!success) {
                     loadFailedList.push(imageName);
                 }
@@ -834,7 +837,12 @@ async function startService(options: TestOptions, service: Service): Promise<()
 
     if (options.testPlatform === 'kubernetes' || options.testPlatform === 'kubernetesV2') {
         const kind = new Kind(config.K8S_VERSION, options.kindClusterName);
-        await kind.loadServiceImage(service, services[service].image, version);
+        await kind.loadServiceImage(
+            service,
+            services[service].image,
+            version,
+            options.skipImageDeletion
+        );
         await k8sStopService(service);
         await k8sStartService(service, services[service].image, version, kind);
         return () => { };
diff --git a/packages/scripts/test/service-spec.ts b/packages/scripts/test/service-spec.ts
index a715db0e988..e6469d1b7a0 100644
--- a/packages/scripts/test/service-spec.ts
+++ b/packages/scripts/test/service-spec.ts
@@ -110,7 +110,8 @@ describe('services', () => {
         encryptMinio: false,
         ignoreMount: false,
         testPlatform: 'native',
-        kindClusterName: 'default'
+        kindClusterName: 'default',
+        skipImageDeletion: false
     };
     let services: any;
 
diff --git a/packages/scripts/test/test-runner-spec.ts b/packages/scripts/test/test-runner-spec.ts
index 514be3a02fb..a3cb8516b62 100644
--- a/packages/scripts/test/test-runner-spec.ts
+++ b/packages/scripts/test/test-runner-spec.ts
@@ -21,7 +21,8 @@ describe('Test Runner Helpers', () => {
         encryptMinio: false,
         ignoreMount: true,
         testPlatform: 'native',
-        kindClusterName: 'default'
+        kindClusterName: 'default',
+        skipImageDeletion: false
     };
 
     function makeTestOptions(input: Partial<TestOptions>): TestOptions {