diff --git a/src/actions/dataImport.ts b/src/actions/dataImport.ts
index 37a3aed..3eadd0f 100644
--- a/src/actions/dataImport.ts
+++ b/src/actions/dataImport.ts
@@ -9,6 +9,7 @@ import { AuthCredentials } from "../pac/auth/authParameters";
 export interface DataImportParameters extends CommonActionParameters {
   credentials: AuthCredentials;
   dataFile: HostParameterEntry;
+  connectionCount: HostParameterEntry
   verbose: HostParameterEntry;
   environmentUrl: string;
 }
@@ -29,6 +30,7 @@ export async function dataImport(parameters: DataImportParameters, runnerParamet
     logger.log("The Authentication Result: " + authenticateResult);
 
     validator.pushInput(pacArgs, "--data", parameters.dataFile);
+    validator.pushInput(pacArgs, "--connection-count", parameters.connectionCount);
     validator.pushInput(pacArgs, "--verbose", parameters.verbose);
     validator.pushCommon(pacArgs, parameters);
 
diff --git a/test/actions/dataImport.test.ts b/test/actions/dataImport.test.ts
index 969f51e..4e428ab 100644
--- a/test/actions/dataImport.test.ts
+++ b/test/actions/dataImport.test.ts
@@ -53,6 +53,7 @@ describe("action: dataImport", () => {
   const createMinMockParameters = (): DataImportParameters => ({
     credentials: mockClientCredentials,
     dataFile: { name: "DataFile", required: true },
+    connectionCount: { name: "ConnectionCount", required: false },
     verbose: { name: "Verbose", required: false },
     environmentUrl: envUrl,
     logToConsole: false