FEAT: update connectors

2026-10-04 10:29:09 +00:00 · 2026-04-07 18:05:30 -03:00
1 changed files with 8 additions and 1 deletions
@@ -422,6 +422,7 @@ export class PipelinesService implements OnModuleInit {
    try {
      await this.updatePlatformJobs(
        pipelineIdFormat,
+        updateInputResponse.input.type,
        updateInputDTO,
        user
      );
@@ -487,7 +488,7 @@ export class PipelinesService implements OnModuleInit {

  }

-  async updatePlatformJobs(pipelineId: string, updateInputDTO: UpdatePlatformInputRequest, user: RequestUser) {
+  async updatePlatformJobs(pipelineId: string, pipelineType: string, updateInputDTO: UpdatePlatformInputRequest, user: RequestUser) {
    const jobsUpdated = [];

    for (const [index, table] of updateInputDTO.tables.entries()) {
@@ -528,8 +529,14 @@ export class PipelinesService implements OnModuleInit {

      if (table.type) {
        hasUpdateSyncMode = true;
+        
        jobSyncMode['target_load_type'] = table.type;
+      }

+      if (table.type === "full_load" && pipelineType === "application") {
+        hasUpdateSyncMode = true;
+        
+        jobSyncMode['target_load_type'] = "FULL_TABLE";
      }

      if(hasUpdateSyncMode) {