Skip to content

Commit f6ac453

Browse files
committed
add overwrite pipeline option
1 parent df98a35 commit f6ac453

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

commands/import/pipelines.js

+2-2
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ const { importPipelines } = require('../../utils/importUtils');
55

66
async function importPipelineData(argv) {
77
try {
8-
const { inputDirectory } = argv;
8+
const { inputDirectory, overwrite } = argv;
99
if (!fs.existsSync(inputDirectory)) {
1010
console.error(`Directory "${inputDirectory}" does not exist.`);
1111
return;
@@ -38,7 +38,7 @@ async function importPipelineData(argv) {
3838
}
3939
}
4040

41-
await importPipelines(argv, parsedPipelines);
41+
await importPipelines(argv, parsedPipelines, overwrite);
4242
}
4343
catch (error) {
4444
console.error(`Error importing pipelines: ${error.message}`);

utils/importUtils.js

+2-2
Original file line numberDiff line numberDiff line change
@@ -17,11 +17,11 @@ async function importAlgorithms(argv, algorithmData, overwrite) {
1717
});
1818
}
1919

20-
async function importPipelines(argv, pipelinedata) {
20+
async function importPipelines(argv, pipelinedata, overwrite) {
2121
const pipePath = 'store/pipelines';
2222
const response = await post({
2323
...argv,
24-
path: pipePath,
24+
path: `${pipePath}?overwrite=${overwrite}`,
2525
body: pipelinedata,
2626
});
2727
response.result.forEach((result) => {

0 commit comments

Comments
 (0)