gitea_admin/maestro
1
0
Fork 0
mirror of https://github.com/dadosfera/maestro.git synced 2026-11-07 04:49:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

FIX: adjusting pipeline payload fixed

Browse Source
This commit is contained in:
Gabriel Rosa
2022-05-20 08:50:08 -03:00
parent 45477b5750
commit 6be53bebaf
5 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/modules/pipelines/pipelines.service.ts
+4 -4
View File
@@ -8,7 +8,7 @@ export class PipelinesService {
constructor(private pipelineClient: PipelinesClientService) {}
adjustPayload(payload) {
payload.input = payload.input.input_s3 || payload.input.input_jdbc;
payload.input = payload.input?.input_s3 || payload.input?.input_jdbc;
}
async create(createPipelineDto) {
@@ -18,7 +18,7 @@ export class PipelinesService {
);
const pipeline = objectCamelToSnake(createPipelineResponse);
this.adjustPayload(pipeline);
this.adjustPayload(pipeline.pipeline);
return pipeline;
} catch (err) {
@@ -32,7 +32,7 @@ export class PipelinesService {
const findOnePipelineResponse = await this.pipelineClient.findOne(data);
const pipeline = objectCamelToSnake(findOnePipelineResponse);
this.adjustPayload(pipeline);
this.adjustPayload(pipeline.pipeline);
return pipeline;
} catch (err) {
@@ -48,7 +48,7 @@ export class PipelinesService {
pipelines.forEach((pipeline) => {
this.adjustPayload(pipeline);
});
return pipelines;
return { pipelines };
} catch (err) {
throw new HttpException(err.message, HttpStatus.NOT_FOUND);
}