From 957984b4c7ef238b816675dafa0394e4c3a17c37 Mon Sep 17 00:00:00 2001
From: "adel.kalimullin" <a.kalimullin@micord.ru>
Date: Thu, 4 Sep 2025 13:17:31 +0300
Subject: [PATCH] fix after merge

---
 ...lta_citizen_liability_fz53_flow2_error.hpl | 100 ++++++++++--------
 1 file changed, 53 insertions(+), 47 deletions(-)

diff --git a/map_v1/info_recruits/citizen_tables/citizen_liability_fz53/checkpoints/change_status_delta_citizen_liability_fz53_flow2_error.hpl b/map_v1/info_recruits/citizen_tables/citizen_liability_fz53/checkpoints/change_status_delta_citizen_liability_fz53_flow2_error.hpl
index f0b4186..17d98b1 100644
--- a/map_v1/info_recruits/citizen_tables/citizen_liability_fz53/checkpoints/change_status_delta_citizen_liability_fz53_flow2_error.hpl
+++ b/map_v1/info_recruits/citizen_tables/citizen_liability_fz53/checkpoints/change_status_delta_citizen_liability_fz53_flow2_error.hpl
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <pipeline>
   <info>
-    <name>recruit_update_date_ervu_dashboard</name>
+    <name>change_status_delta_citizen_liability_fz53_flow2_error</name>
     <name_sync_with_filename>Y</name_sync_with_filename>
     <description/>
     <extended_description/>
@@ -13,19 +13,63 @@
     <transform_performance_capturing_delay>1000</transform_performance_capturing_delay>
     <transform_performance_capturing_size_limit>100</transform_performance_capturing_size_limit>
     <created_user>-</created_user>
-    <created_date>2025/06/02 14:50:31.833</created_date>
+    <created_date>2025/06/16 12:20:06.191</created_date>
     <modified_user>-</modified_user>
-    <modified_date>2025/06/02 14:50:31.833</modified_date>
+    <modified_date>2025/06/16 12:20:06.191</modified_date>
   </info>
   <notepads>
   </notepads>
   <order>
     <hop>
       <from>Table input</from>
-      <to>Table output</to>
+      <to>Insert / update</to>
       <enabled>Y</enabled>
     </hop>
   </order>
+  <transform>
+    <name>Insert / update</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <commit>100</commit>
+    <connection>ervu-dashboard</connection>
+    <lookup>
+      <key>
+        <condition>=</condition>
+        <field>job_name</field>
+        <name>job_name</name>
+      </key>
+      <schema>public</schema>
+      <table>etl_checkpoints</table>
+      <value>
+        <name>job_name</name>
+        <rename>job_name</rename>
+        <update>N</update>
+      </value>
+      <value>
+        <name>record_created</name>
+        <rename>record_created</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>status</name>
+        <rename>status</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <update_bypassed>N</update_bypassed>
+    <attributes/>
+    <GUI>
+      <xloc>1152</xloc>
+      <yloc>304</yloc>
+    </GUI>
+  </transform>
   <transform>
     <name>Table input</name>
     <type>TableInput</type>
@@ -40,52 +84,14 @@
     <connection>ervu-dashboard</connection>
     <execute_each_row>N</execute_each_row>
     <limit>0</limit>
-    <sql>SELECT 
-    created_at AS system_create_date,
-    updated_at AS system_update_date,
-    current_timestamp AS record_created,
-    'job_recruits_info' AS workflow
-FROM ervu_dashboard.recruits_info
-WHERE updated_at = (SELECT MAX(updated_at) FROM ervu_dashboard.recruits_info)
-limit 1</sql>
+    <sql>    SELECT
+        'delta_citizen_liability_fz53_flow2' as job_name,
+        'ERROR' as status,
+        current_timestamp as record_created</sql>
     <variables_active>N</variables_active>
     <attributes/>
     <GUI>
-      <xloc>896</xloc>
-      <yloc>304</yloc>
-    </GUI>
-  </transform>
-  <transform>
-    <name>Table output</name>
-    <type>TableOutput</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <commit>1000</commit>
-    <connection>ervu-dashboard</connection>
-    <fields>
-</fields>
-    <ignore_errors>N</ignore_errors>
-    <only_when_have_rows>N</only_when_have_rows>
-    <partitioning_daily>N</partitioning_daily>
-    <partitioning_enabled>N</partitioning_enabled>
-    <partitioning_monthly>Y</partitioning_monthly>
-    <return_keys>N</return_keys>
-    <schema>public</schema>
-    <specify_fields>N</specify_fields>
-    <table>recruit_create</table>
-    <tablename_in_field>N</tablename_in_field>
-    <tablename_in_table>Y</tablename_in_table>
-    <truncate>N</truncate>
-    <use_batch>Y</use_batch>
-    <attributes/>
-    <GUI>
-      <xloc>1216</xloc>
+      <xloc>784</xloc>
       <yloc>304</yloc>
     </GUI>
   </transform>