🚀 Socket Launch Week Day 5:Introducing Repository Access Permissions and Custom Roles.Learn more →
Sign In

@grouparoo/redshift

Package Overview
Dependencies
Maintainers
6
Versions
218
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@grouparoo/redshift - npm Package Compare versions

Comparing version
0.8.2-alpha.0
 to
0.8.2-alpha.1
+2
-71
__tests__/integration/redshiftTableImport.ts

@@ -299,30 +299,5 @@ import path from "path";

// run all enqueued associateRecord tasks
const foundAssociateTasks = await specHelper.findEnqueuedTasks(
"import:associateRecord"
);
expect(foundAssociateTasks.length).toEqual(11);
await Promise.all(
foundAssociateTasks.map(
async (t) =>
await specHelper.runTask("import:associateRecord", t.args[0])
)
);
await specHelper.runTask("import:associateRecords", {});
await ImportWorkflow();
// run all enqueued export tasks
const foundExportTasks = await specHelper.findEnqueuedTasks(
"record:export"
);
// this count is de-duped from the previous run
expect(foundExportTasks.length).toEqual(10);
await Promise.all(
foundExportTasks.map((t) =>
specHelper.runTask("record:export", t.args[0])
)
);
// run the export:enqueue task

@@ -340,12 +315,2 @@ await specHelper.runTask("export:enqueue", {});

// check if the run is done
const foundRunDetermineStateTasks = await specHelper.findEnqueuedTasks(
"run:determineState"
);
await Promise.all(
foundRunDetermineStateTasks.map((t) =>
specHelper.runTask("run:determineState", t.args[0])
)
);
// check the results of the run

@@ -407,29 +372,5 @@ const recordsCount = await GrouparooRecord.count();

// run all enqueued associateRecord tasks
const foundAssociateTasks = await specHelper.findEnqueuedTasks(
"import:associateRecord"
);
expect(foundAssociateTasks.length).toEqual(11 + 1);
await Promise.all(
foundAssociateTasks.map((t) =>
specHelper.runTask("import:associateRecord", t.args[0])
)
);
await specHelper.runTask("import:associateRecords", {});
await ImportWorkflow();
// run all enqueued export tasks
const foundExportTasks = await specHelper.findEnqueuedTasks(
"record:export"
);
// this count is de-duped from the previous run
expect(foundExportTasks.length).toEqual(10);
await Promise.all(
foundExportTasks.map((t) =>
specHelper.runTask("record:export", t.args[0])
)
);
// run the export:enqueue task

@@ -442,12 +383,2 @@ await specHelper.runTask("export:enqueue", {});

// check if the run is done
const foundRunDetermineStateTasks = await specHelper.findEnqueuedTasks(
"run:determineState"
);
await Promise.all(
foundRunDetermineStateTasks.map((t) =>
specHelper.runTask("run:determineState", t.args[0])
)
);
// check the results of the run

@@ -454,0 +385,0 @@ const recordsCount = await GrouparooRecord.count();

+9
-9
package.json

@@ -5,3 +5,3 @@ {

"description": "The Grouparoo redshift Plugin",
"version": "0.8.2-alpha.0",
"version": "0.8.2-alpha.1",
"license": "MPL-2.0",

@@ -32,8 +32,8 @@ "private": false,

"dependencies": {
"@grouparoo/app-templates": "0.8.2-alpha.0",
"@grouparoo/postgres": "0.8.2-alpha.0"
"@grouparoo/app-templates": "0.8.2-alpha.1",
"@grouparoo/postgres": "0.8.2-alpha.1"
},
"devDependencies": {
"@grouparoo/core": "0.8.2-alpha.0",
"@grouparoo/spec-helper": "0.8.2-alpha.0",
"@grouparoo/core": "0.8.2-alpha.1",
"@grouparoo/spec-helper": "0.8.2-alpha.1",
"@types/jest": "*",

@@ -43,10 +43,10 @@ "@types/node": "16.*.*",

"actionhero": "28.1.8",
"dotenv": "15.0.0",
"dotenv": "16.0.0",
"jest": "27.5.1",
"prettier": "2.5.1",
"sequelize": "6.15.0",
"sequelize": "6.17.0",
"ts-jest": "27.1.3",
"typescript": "4.5.5"
"typescript": "4.6.2"
},
"gitHead": "2b026c35c0f5ec2009f531448de14570ddd288db"
"gitHead": "991d7c1d76c10436e29dd62ee0b5d50568b08c4a"
}