mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2025-01-13 13:57:29 -08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Revert "add check for arr"

Browse source 
40a43f5957
This commit is contained in:
Mutasem 2022-08-04 16:26:44 +02:00
parent 40a43f5957
commit 59a5d808ce
3 changed files with 0 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
packages/cli/src/databases/migrations/mysqldb/1658932910559-AddNodeIds.ts
View file

@ -20,9 +20,6 @@ export class AddNodeIds1658932910559 implements MigrationInterface {
await runChunked(queryRunner, workflowsQuery, (workflows) => { await runChunked(queryRunner, workflowsQuery, (workflows) => {
workflows.forEach(async (workflow) => { workflows.forEach(async (workflow) => {
const nodes = workflow.nodes; const nodes = workflow.nodes;
if (!Array.isArray(nodes)) {
return;
}
// @ts-ignore // @ts-ignore
nodes.forEach((node) => { nodes.forEach((node) => {
if (!node.id) { if (!node.id) {
@ -58,9 +55,6 @@ export class AddNodeIds1658932910559 implements MigrationInterface {
await runChunked(queryRunner, workflowsQuery, (workflows) => { await runChunked(queryRunner, workflowsQuery, (workflows) => {
workflows.forEach(async (workflow) => { workflows.forEach(async (workflow) => {
const nodes = workflow.nodes; const nodes = workflow.nodes;
if (!Array.isArray(nodes)) {
return;
}
// @ts-ignore // @ts-ignore
nodes.forEach((node) => delete node.id ); nodes.forEach((node) => delete node.id );

8
packages/cli/src/databases/migrations/postgresdb/1658932090381-AddNodeIds.ts
View file

@ -26,10 +26,6 @@ export class AddNodeIds1658932090381 implements MigrationInterface {
await runChunked(queryRunner, workflowsQuery, (workflows) => { await runChunked(queryRunner, workflowsQuery, (workflows) => {
workflows.forEach(async (workflow) => { workflows.forEach(async (workflow) => {
const nodes = workflow.nodes; const nodes = workflow.nodes;
if (!Array.isArray(nodes)) {
return;
}
// @ts-ignore // @ts-ignore
nodes.forEach((node) => { nodes.forEach((node) => {
if (!node.id) { if (!node.id) {
@ -71,10 +67,6 @@ export class AddNodeIds1658932090381 implements MigrationInterface {
await runChunked(queryRunner, workflowsQuery, (workflows) => { await runChunked(queryRunner, workflowsQuery, (workflows) => {
workflows.forEach(async (workflow) => { workflows.forEach(async (workflow) => {
const nodes = workflow.nodes; const nodes = workflow.nodes;
if (!Array.isArray(nodes)) {
return;
}
// @ts-ignore // @ts-ignore
nodes.forEach((node) => delete node.id ); nodes.forEach((node) => delete node.id );

8
packages/cli/src/databases/migrations/sqlite/1658930531669-AddNodeIds.ts
View file

@ -24,10 +24,6 @@ export class AddNodeIds1658930531669 implements MigrationInterface {
await runChunked(queryRunner, workflowsQuery, (workflows) => { await runChunked(queryRunner, workflowsQuery, (workflows) => {
workflows.forEach(async (workflow) => { workflows.forEach(async (workflow) => {
const nodes = JSON.parse(workflow.nodes); const nodes = JSON.parse(workflow.nodes);
if (!Array.isArray(nodes)) {
return;
}
nodes.forEach((node: INode) => { nodes.forEach((node: INode) => {
if (!node.id) { if (!node.id) {
node.id = uuid(); node.id = uuid();
@ -65,10 +61,6 @@ export class AddNodeIds1658930531669 implements MigrationInterface {
await runChunked(queryRunner, workflowsQuery, (workflows) => { await runChunked(queryRunner, workflowsQuery, (workflows) => {
workflows.forEach(async (workflow) => { workflows.forEach(async (workflow) => {
const nodes = JSON.parse(workflow.nodes); const nodes = JSON.parse(workflow.nodes);
if (!Array.isArray(nodes)) {
return;
}
// @ts-ignore // @ts-ignore
nodes.forEach((node) => delete node.id ); nodes.forEach((node) => delete node.id );