diff --git a/src/clients/inputs/client.service.ts b/src/clients/inputs/client.service.ts index dee162e..0ec746d 100644 --- a/src/clients/inputs/client.service.ts +++ b/src/clients/inputs/client.service.ts @@ -1,7 +1,6 @@ import { OnModuleInit, Inject } from '@nestjs/common'; import { ClientGrpc } from '@nestjs/microservices'; import { - InputCreateResponse, InputCreateS3Request, InputNewCreateRequest, InputService, diff --git a/src/modules/inputs/inputs.service.ts b/src/modules/inputs/inputs.service.ts index 03898bd..222abbb 100644 --- a/src/modules/inputs/inputs.service.ts +++ b/src/modules/inputs/inputs.service.ts @@ -153,7 +153,7 @@ export class InputsService { } generateInputS3Payload(payload) { - const { credentials, plugin } = payload; + const { credentials, plugin, cron } = payload; if (!credentials) return payload; const { @@ -164,8 +164,10 @@ export class InputsService { client_bucket, file_to_extract, } = credentials; + const formatedPayload = { plugin, + cron, source_bucket: client_bucket, source_prefix: file_to_extract, auth_parameters: {