diff --git a/src/clients/inputs/client.service.ts b/src/clients/inputs/client.service.ts
index 1360f67..dee162e 100644
--- a/src/clients/inputs/client.service.ts
+++ b/src/clients/inputs/client.service.ts
@@ -1,6 +1,7 @@
 import { OnModuleInit, Inject } from '@nestjs/common';
 import { ClientGrpc } from '@nestjs/microservices';
 import {
+  InputCreateResponse,
   InputCreateS3Request,
   InputNewCreateRequest,
   InputService,
@@ -42,11 +43,9 @@ export class InputsClientService implements OnModuleInit {
             console.log('done');
           },
         });
-    })
-      .then((res) => res)
-      .catch((err) => {
-        throw new Error(err);
-      });
+    }).catch((err) => {
+      throw new Error(err);
+    });
 
     return createInputResponse;
   }
diff --git a/src/modules/inputs/inputs.service.ts b/src/modules/inputs/inputs.service.ts
index 5e03cf4..de2d9b1 100644
--- a/src/modules/inputs/inputs.service.ts
+++ b/src/modules/inputs/inputs.service.ts
@@ -22,7 +22,10 @@ export class InputsService {
         });
         return createInputResponse;
       } else {
-        const createInputResponse = await this.inputClient.create(data);
+        const createInputResponse: any = await this.inputClient.create(data);
+        if (createInputResponse?.input?.input_jdbc) {
+          return { input: createInputResponse?.input?.input_jdbc };
+        }
         return createInputResponse;
       }
     } catch (err) {