From 877cb9d2813eb00a10302e1d02a0e000424b8c7d Mon Sep 17 00:00:00 2001
From: viniciusgadea <vinicius.gadea@dadosfera.ai>
Date: Tue, 31 Mar 2026 18:38:25 -0300
Subject: [PATCH] FEAT: refine PipelineTablesConfig type definition and update
 parsing logic in PipelinesController

---
 src/modules/pipelinesV2/pipelines.controller.ts | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/src/modules/pipelinesV2/pipelines.controller.ts b/src/modules/pipelinesV2/pipelines.controller.ts
index 5e6456e..37b3a47 100644
--- a/src/modules/pipelinesV2/pipelines.controller.ts
+++ b/src/modules/pipelinesV2/pipelines.controller.ts
@@ -54,6 +54,9 @@ import { TableColumns } from '../inputs/dtos/input.model';
 import { UpdateInputRequest } from '../inputs/dtos/old_interfaces';
 import { Info } from '@dadosfera/protospack-v2/dist/lib/Input/interfaces/entities';
 
+type PipelineTable = { name: string; job_id?: string; is_deleted?: boolean; [key: string]: any };
+type PipelineTablesConfig = { input_id?: string; tables?: PipelineTable[] } | PipelineTable[];
+
 @ApiTags('PipelinesV2')
 @ApiHeaders([{ name: 'dadosfera-lang', enum: LanguageEnum, required: false }])
 @UseFilters(new GrpcToHttpExceptionFilter())
@@ -63,6 +66,7 @@ export class PipelinesController {
   constructor(
     @Inject(DadosferaLogger)
     dadosferaLogger: DadosferaLogger,
+
     private pipelinesClientService: PipelinesService,
     private oldPipelinesService: OldPipelineService,
     private platformApiService: PlatformApiService,
@@ -229,11 +233,9 @@ export class PipelinesController {
       this.platformApiService.proxy('GET', `/pipeline/${id.replace(/-/g, '_')}`, user).catch(() => null),
     ]);
 
-    //{pipeline:{tables: {tables: [], input_id: ''}}}
-    type PipelineTablesConfig = { input_id?: string; tables?: Array<{ name: string }> } | Array<{ name: string }>;
     const parsed: PipelineTablesConfig = JSON.parse(pipelineRes.pipeline.config.tables);
-    const input_id = (parsed as { input_id?: string })?.input_id;
-    let tables: Array<any> = (parsed as { tables?: Array<any> })?.tables ?? (parsed as Array<any>);
+    const input_id = (parsed as { input_id?: string; tables?: PipelineTable[] })?.input_id;
+    let tables: PipelineTable[] = (parsed as { tables?: PipelineTable[] })?.tables ?? (parsed as PipelineTable[]);
 
     if (platformPipeline?.jobs?.length) {
       tables = tables.map((table) => {