From f36eaaf8be67f4eee7b50ab4a548699691a81b23 Mon Sep 17 00:00:00 2001
From: Fusionshh <sabzeroifusion@gmail.com>
Date: Mon, 20 Oct 2025 16:20:57 +0300
Subject: [PATCH] some fixes

---
 .../parallel/russian_diploma_flow_delta.hpl   | 39 ++++---------------
 .../parallel/russian_diploma_flow_repeat.hpl  | 16 +++++---
 2 files changed, 17 insertions(+), 38 deletions(-)

diff --git a/mappings/info_recruits/citizen_tables/education/russian_diploma/parallel/russian_diploma_flow_delta.hpl b/mappings/info_recruits/citizen_tables/education/russian_diploma/parallel/russian_diploma_flow_delta.hpl
index 83fd0f7..74cf1ce 100644
--- a/mappings/info_recruits/citizen_tables/education/russian_diploma/parallel/russian_diploma_flow_delta.hpl
+++ b/mappings/info_recruits/citizen_tables/education/russian_diploma/parallel/russian_diploma_flow_delta.hpl
@@ -93,11 +93,6 @@
     </hop>
     <hop>
       <from>Insert / update</from>
-      <to>Block until transforms finish</to>
-      <enabled>Y</enabled>
-    </hop>
-    <hop>
-      <from>Block until transforms finish</from>
       <to>Filter rows</to>
       <enabled>Y</enabled>
     </hop>
@@ -122,28 +117,6 @@
       <yloc>656</yloc>
     </GUI>
   </transform>
-  <transform>
-    <name>Block until transforms finish</name>
-    <type>BlockUntilTransformsFinish</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <transforms>
-      <transform>
-        <name>Update</name>
-      </transform>
-    </transforms>
-    <attributes/>
-    <GUI>
-      <xloc>1312</xloc>
-      <yloc>464</yloc>
-    </GUI>
-  </transform>
   <transform>
     <name>Change job status on error</name>
     <type>ExecSql</type>
@@ -435,20 +408,23 @@ and recruitment_id = '${IDM_ID}';</sql>
       <method>none</method>
       <schema_name/>
     </partitioning>
-    <compress>N</compress>
     <directory>${java.io.tmpdir}</directory>
+    <prefix/>
+    <sort_size>1000000</sort_size>
+    <free_memory/>
+    <compress>N</compress>
+    <compress_variable/>
+    <unique_rows>Y</unique_rows>
     <fields>
       <field>
+        <name>recruit_id</name>
         <ascending>Y</ascending>
         <case_sensitive>N</case_sensitive>
         <collator_enabled>N</collator_enabled>
         <collator_strength>0</collator_strength>
-        <name>recruit_id</name>
         <presorted>N</presorted>
       </field>
     </fields>
-    <sort_size>1000000</sort_size>
-    <unique_rows>Y</unique_rows>
     <attributes/>
     <GUI>
       <xloc>880</xloc>
@@ -503,7 +479,6 @@ and recruitment_id = '${IDM_ID}';</sql>
     </partitioning>
     <connection>ervu-dashboard</connection>
     <execute_each_row>N</execute_each_row>
-    <limit/>
     <sql>
 WITH filteredData AS (SELECT ri.recruit_id,
                              ri.info -> 'svedFL' -> 'svedRObr' -> 'robr' as diploma_arr
diff --git a/mappings/info_recruits/citizen_tables/education/russian_diploma/parallel/russian_diploma_flow_repeat.hpl b/mappings/info_recruits/citizen_tables/education/russian_diploma/parallel/russian_diploma_flow_repeat.hpl
index a73e13c..753a286 100644
--- a/mappings/info_recruits/citizen_tables/education/russian_diploma/parallel/russian_diploma_flow_repeat.hpl
+++ b/mappings/info_recruits/citizen_tables/education/russian_diploma/parallel/russian_diploma_flow_repeat.hpl
@@ -431,20 +431,23 @@ ON CONFLICT (job_name, recruitment_id)
       <method>none</method>
       <schema_name/>
     </partitioning>
-    <compress>N</compress>
     <directory>${java.io.tmpdir}</directory>
+    <prefix/>
+    <sort_size>1000000</sort_size>
+    <free_memory/>
+    <compress>N</compress>
+    <compress_variable/>
+    <unique_rows>Y</unique_rows>
     <fields>
       <field>
+        <name>recruit_id</name>
         <ascending>Y</ascending>
         <case_sensitive>N</case_sensitive>
         <collator_enabled>N</collator_enabled>
         <collator_strength>0</collator_strength>
-        <name>recruit_id</name>
         <presorted>N</presorted>
       </field>
     </fields>
-    <sort_size>1000000</sort_size>
-    <unique_rows>Y</unique_rows>
     <attributes/>
     <GUI>
       <xloc>624</xloc>
@@ -465,11 +468,13 @@ ON CONFLICT (job_name, recruitment_id)
     <commit>10000</commit>
     <connection>ervu-dashboard</connection>
     <error_ignored>N</error_ignored>
+    <ignore_flag_field/>
     <lookup>
       <key>
         <condition>=</condition>
         <field>recruit_id</field>
         <name>recruit_id</name>
+        <name2/>
       </key>
       <schema>ervu_dashboard</schema>
       <table>citizen</table>
@@ -499,7 +504,6 @@ ON CONFLICT (job_name, recruitment_id)
     </partitioning>
     <connection>ervu-dashboard</connection>
     <execute_each_row>N</execute_each_row>
-    <limit/>
     <sql>WITH filteredData AS (SELECT ri.recruit_id,
                              ri.info -> 'svedFL' -> 'svedRObr' -> 'robr' AS diploma_arr
                       FROM ervu_dashboard.recruits_info ri
@@ -550,7 +554,7 @@ FROM filteredData fd
       <target_transform>Change job status on error</target_transform>
       <is_enabled>Y</is_enabled>
       <nr_valuename/>
-      <descriptions_valuename/>
+      <descriptions_valuename>error_description</descriptions_valuename>
       <fields_valuename/>
       <codes_valuename/>
       <max_errors/>