From 6fd41db91b6410bdb47fdd54b0d7eb3e1a37b178 Mon Sep 17 00:00:00 2001
From: "adel.ka" <a.kalimullin@micord.ru>
Date: Fri, 14 Nov 2025 14:05:46 +0300
Subject: [PATCH] =?UTF-8?q?=D1=84=D0=B8=D0=BA=D1=81=20rdi=20=D0=B8=20rd?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../parallel/restriction_document_flow.hpl    | 194 +++++++-------
 .../restriction_document_flow_delta.hpl       |  90 +++----
 .../restriction_document_flow_repeat.hpl      | 138 +++++-----
 .../recruitment_five_flow_delta.hpl           | 225 +++++++++++++---
 .../restriction_document_item_flow.hpl        | 224 ++++++++--------
 .../restriction_document_item_flow_delta.hpl  | 240 +++++++++---------
 .../restriction_document_item_flow_repeat.hpl | 227 ++++++++---------
 .../recruitment_five_flow_delta.hpl           | 217 +++++++++++++---
 8 files changed, 911 insertions(+), 644 deletions(-)

diff --git a/mappings/info_recruits/raw_data/restriction_document/parallel/restriction_document_flow.hpl b/mappings/info_recruits/raw_data/restriction_document/parallel/restriction_document_flow.hpl
index eaa3249..ca36184 100644
--- a/mappings/info_recruits/raw_data/restriction_document/parallel/restriction_document_flow.hpl
+++ b/mappings/info_recruits/raw_data/restriction_document/parallel/restriction_document_flow.hpl
@@ -21,53 +21,82 @@
   </notepads>
   <order>
     <hop>
-      <from>Create job execution record</from>
-      <to>Table input</to>
+      <from>Create_job_execution_record_RD</from>
+      <to>input_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Filter rows</from>
-      <to>Change job status on success</to>
+      <from>filter_rows_RD</from>
+      <to>сhange_status_on_success_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Detect empty stream</from>
-      <to>Change job status on success</to>
+      <from>detect_empty_stream_RD</from>
+      <to>сhange_status_on_success_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Change job status on error</from>
-      <to>Abort</to>
+      <from>change_job_status_on_error_RD</from>
+      <to>abort_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table input</from>
-      <to>Identify last row in a stream</to>
+      <from>output_RD</from>
+      <to>change_job_status_on_error_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Identify last row in a stream</from>
-      <to>Table output</to>
+      <from>output_RD</from>
+      <to>detect_empty_stream_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table output</from>
-      <to>Filter rows</to>
+      <from>output_RD</from>
+      <to>identify_last_row_in_a_stream_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table output</from>
-      <to>Change job status on error</to>
+      <from>identify_last_row_in_a_stream_RD</from>
+      <to>filter_rows_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table output</from>
-      <to>Detect empty stream</to>
+      <from>input_RD</from>
+      <to>output_RD</to>
       <enabled>Y</enabled>
     </hop>
   </order>
   <transform>
-    <name>Abort</name>
+    <name>Create_job_execution_record_RD</name>
+    <type>ExecSql</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <arguments>
+</arguments>
+    <connection>ervu-dashboard</connection>
+    <execute_each_row>N</execute_each_row>
+    <quoteString>N</quoteString>
+    <replace_variables>Y</replace_variables>
+    <set_params>N</set_params>
+    <single_statement>N</single_statement>
+    <sql>INSERT INTO etl.job_execution (id, job_name, status, execution_datetime, error_description, recruitment_id)
+VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}');
+
+</sql>
+    <attributes/>
+    <GUI>
+      <xloc>288</xloc>
+      <yloc>400</yloc>
+    </GUI>
+  </transform>
+  <transform>
+    <name>abort_RD</name>
     <type>Abort</type>
     <description/>
     <distribute>Y</distribute>
@@ -83,11 +112,11 @@
     <attributes/>
     <GUI>
       <xloc>1376</xloc>
-      <yloc>512</yloc>
+      <yloc>592</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Change job status on error</name>
+    <name>change_job_status_on_error_RD</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -118,71 +147,11 @@ and recruitment_id = '${IDM_ID}';
     <attributes/>
     <GUI>
       <xloc>1024</xloc>
-      <yloc>512</yloc>
+      <yloc>592</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Change job status on success</name>
-    <type>ExecSql</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <arguments>
-</arguments>
-    <connection>ervu-dashboard</connection>
-    <execute_each_row>Y</execute_each_row>
-    <quoteString>N</quoteString>
-    <replace_variables>Y</replace_variables>
-    <set_params>N</set_params>
-    <single_statement>N</single_statement>
-    <sql>UPDATE etl.job_execution
-SET status = 'SUCCESS'
-WHERE job_name = '${JOB_NAME}'
-and recruitment_id = '${IDM_ID}';
-
-</sql>
-    <attributes/>
-    <GUI>
-      <xloc>1632</xloc>
-      <yloc>160</yloc>
-    </GUI>
-  </transform>
-  <transform>
-    <name>Create job execution record</name>
-    <type>ExecSql</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <arguments>
-</arguments>
-    <connection>ervu-dashboard</connection>
-    <execute_each_row>N</execute_each_row>
-    <quoteString>N</quoteString>
-    <replace_variables>Y</replace_variables>
-    <set_params>N</set_params>
-    <single_statement>N</single_statement>
-    <sql>INSERT INTO etl.job_execution (id, job_name, status, execution_datetime, error_description, recruitment_id)
-VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}');
-
-</sql>
-    <attributes/>
-    <GUI>
-      <xloc>288</xloc>
-      <yloc>320</yloc>
-    </GUI>
-  </transform>
-  <transform>
-    <name>Detect empty stream</name>
+    <name>detect_empty_stream_RD</name>
     <type>DetectEmptyStream</type>
     <description/>
     <distribute>Y</distribute>
@@ -195,11 +164,11 @@ VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}');
     <attributes/>
     <GUI>
       <xloc>1632</xloc>
-      <yloc>320</yloc>
+      <yloc>400</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Filter rows</name>
+    <name>filter_rows_RD</name>
     <type>FilterRows</type>
     <description/>
     <distribute>Y</distribute>
@@ -227,15 +196,15 @@ VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}');
         </value>
       </condition>
     </compare>
-    <send_true_to>Change job status on success</send_true_to>
+    <send_true_to>сhange_status_on_success_RD</send_true_to>
     <attributes/>
     <GUI>
       <xloc>1024</xloc>
-      <yloc>160</yloc>
+      <yloc>64</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Identify last row in a stream</name>
+    <name>identify_last_row_in_a_stream_RD</name>
     <type>DetectLastRow</type>
     <description/>
     <distribute>Y</distribute>
@@ -248,12 +217,12 @@ VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}');
     <resultfieldname>last_row</resultfieldname>
     <attributes/>
     <GUI>
-      <xloc>752</xloc>
-      <yloc>320</yloc>
+      <xloc>1024</xloc>
+      <yloc>224</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Table input</name>
+    <name>input_RD</name>
     <type>TableInput</type>
     <description/>
     <distribute>N</distribute>
@@ -275,12 +244,12 @@ WHERE
     <variables_active>Y</variables_active>
     <attributes/>
     <GUI>
-      <xloc>496</xloc>
-      <yloc>320</yloc>
+      <xloc>640</xloc>
+      <yloc>400</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Table output</name>
+    <name>output_RD</name>
     <type>TableOutput</type>
     <description/>
     <distribute>N</distribute>
@@ -366,13 +335,44 @@ WHERE
     <attributes/>
     <GUI>
       <xloc>1024</xloc>
-      <yloc>320</yloc>
+      <yloc>400</yloc>
+    </GUI>
+  </transform>
+  <transform>
+    <name>сhange_status_on_success_RD</name>
+    <type>ExecSql</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <arguments>
+</arguments>
+    <connection>ervu-dashboard</connection>
+    <execute_each_row>Y</execute_each_row>
+    <quoteString>N</quoteString>
+    <replace_variables>Y</replace_variables>
+    <set_params>N</set_params>
+    <single_statement>N</single_statement>
+    <sql>UPDATE etl.job_execution
+SET status = 'SUCCESS'
+WHERE job_name = '${JOB_NAME}'
+and recruitment_id = '${IDM_ID}';
+
+</sql>
+    <attributes/>
+    <GUI>
+      <xloc>1632</xloc>
+      <yloc>64</yloc>
     </GUI>
   </transform>
   <transform_error_handling>
     <error>
-      <source_transform>Table output</source_transform>
-      <target_transform>Change job status on error</target_transform>
+      <source_transform>output_RD</source_transform>
+      <target_transform>change_job_status_on_error_RD</target_transform>
       <is_enabled>Y</is_enabled>
       <nr_valuename/>
       <descriptions_valuename>error_description</descriptions_valuename>
diff --git a/mappings/info_recruits/raw_data/restriction_document/parallel/restriction_document_flow_delta.hpl b/mappings/info_recruits/raw_data/restriction_document/parallel/restriction_document_flow_delta.hpl
index 592136d..1f79c2a 100644
--- a/mappings/info_recruits/raw_data/restriction_document/parallel/restriction_document_flow_delta.hpl
+++ b/mappings/info_recruits/raw_data/restriction_document/parallel/restriction_document_flow_delta.hpl
@@ -21,53 +21,53 @@
   </notepads>
   <order>
     <hop>
-      <from>Create job execution record</from>
-      <to>Table input</to>
+      <from>create_job_execution_record_RD</from>
+      <to>table_input_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table input</from>
-      <to>Identify last row in a stream</to>
+      <from>detect_empty_stream_RD</from>
+      <to>change_job_status_on_success_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Detect empty stream</from>
-      <to>Change job status on success</to>
+      <from>filter_rows_RD</from>
+      <to>change_job_status_on_success_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Filter rows</from>
-      <to>Change job status on success</to>
+      <from>change_job_status_on_error_RD</from>
+      <to>abort_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Change job status on error</from>
-      <to>Abort</to>
+      <from>insert_or_update_RD</from>
+      <to>detect_empty_stream_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Identify last row in a stream</from>
-      <to>Insert / update</to>
+      <from>insert_or_update_RD</from>
+      <to>change_job_status_on_error_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Insert / update</from>
-      <to>Filter rows</to>
+      <from>insert_or_update_RD</from>
+      <to>identify_last_row_in_a_stream_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Insert / update</from>
-      <to>Detect empty stream</to>
+      <from>identify_last_row_in_a_stream_RD</from>
+      <to>filter_rows_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Insert / update</from>
-      <to>Change job status on error</to>
+      <from>table_input_RD</from>
+      <to>insert_or_update_RD</to>
       <enabled>Y</enabled>
     </hop>
   </order>
   <transform>
-    <name>Abort</name>
+    <name>abort_RD</name>
     <type>Abort</type>
     <description/>
     <distribute>Y</distribute>
@@ -83,11 +83,11 @@
     <attributes/>
     <GUI>
       <xloc>1168</xloc>
-      <yloc>400</yloc>
+      <yloc>544</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Change job status on error</name>
+    <name>change_job_status_on_error_RD</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -118,11 +118,11 @@ and recruitment_id = '${IDM_ID}';
     <attributes/>
     <GUI>
       <xloc>944</xloc>
-      <yloc>400</yloc>
+      <yloc>544</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Change job status on success</name>
+    <name>change_job_status_on_success_RD</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -153,7 +153,7 @@ and recruitment_id = '${IDM_ID}';
     </GUI>
   </transform>
   <transform>
-    <name>Create job execution record</name>
+    <name>create_job_execution_record_RD</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -181,11 +181,11 @@ and recruitment_id = '${IDM_ID}';</sql>
     <attributes/>
     <GUI>
       <xloc>336</xloc>
-      <yloc>224</yloc>
+      <yloc>368</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Detect empty stream</name>
+    <name>detect_empty_stream_RD</name>
     <type>DetectEmptyStream</type>
     <description/>
     <distribute>Y</distribute>
@@ -198,11 +198,11 @@ and recruitment_id = '${IDM_ID}';</sql>
     <attributes/>
     <GUI>
       <xloc>1248</xloc>
-      <yloc>224</yloc>
+      <yloc>368</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Filter rows</name>
+    <name>filter_rows_RD</name>
     <type>FilterRows</type>
     <description/>
     <distribute>Y</distribute>
@@ -230,7 +230,7 @@ and recruitment_id = '${IDM_ID}';</sql>
         </value>
       </condition>
     </compare>
-    <send_true_to>Change job status on success</send_true_to>
+    <send_true_to>change_job_status_on_success_RD</send_true_to>
     <attributes/>
     <GUI>
       <xloc>944</xloc>
@@ -238,7 +238,7 @@ and recruitment_id = '${IDM_ID}';</sql>
     </GUI>
   </transform>
   <transform>
-    <name>Identify last row in a stream</name>
+    <name>identify_last_row_in_a_stream_RD</name>
     <type>DetectLastRow</type>
     <description/>
     <distribute>Y</distribute>
@@ -251,12 +251,12 @@ and recruitment_id = '${IDM_ID}';</sql>
     <resultfieldname>last_row</resultfieldname>
     <attributes/>
     <GUI>
-      <xloc>736</xloc>
-      <yloc>224</yloc>
+      <xloc>944</xloc>
+      <yloc>208</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Insert / update</name>
+    <name>insert_or_update_RD</name>
     <type>InsertUpdate</type>
     <description/>
     <distribute>N</distribute>
@@ -274,11 +274,6 @@ and recruitment_id = '${IDM_ID}';</sql>
         <field>id</field>
         <name>id</name>
       </key>
-      <key>
-        <condition>=</condition>
-        <field>created_at</field>
-        <name>created_at</name>
-      </key>
       <schema>ervu_dashboard</schema>
       <table>restriction_document</table>
       <value>
@@ -289,12 +284,12 @@ and recruitment_id = '${IDM_ID}';</sql>
       <value>
         <name>subpoena_id</name>
         <rename>subpoena_id</rename>
-        <update>Y</update>
+        <update>N</update>
       </value>
       <value>
         <name>created_at</name>
         <rename>created_at</rename>
-        <update>N</update>
+        <update>Y</update>
       </value>
       <value>
         <name>updated_at</name>
@@ -356,11 +351,11 @@ and recruitment_id = '${IDM_ID}';</sql>
     <attributes/>
     <GUI>
       <xloc>944</xloc>
-      <yloc>224</yloc>
+      <yloc>368</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Table input</name>
+    <name>table_input_RD</name>
     <type>TableInput</type>
     <description/>
     <distribute>N</distribute>
@@ -372,26 +367,25 @@ and recruitment_id = '${IDM_ID}';</sql>
     </partitioning>
     <connection>postgres.subpoena</connection>
     <execute_each_row>N</execute_each_row>
-    <limit/>
     <sql>SELECT
 *
 FROM public.restriction_document 
 WHERE 
     '${IDM_ID}' != ''  -- Проверка на пустую строку
     AND vk_id = '${IDM_ID}'
-    AND updated_at >= '${M_RESTRDOC_UP_DATE}'::timestamp
+    AND updated_at >= '${MAX_UPDATE_DATE}'::timestamp
 </sql>
     <variables_active>Y</variables_active>
     <attributes/>
     <GUI>
-      <xloc>544</xloc>
-      <yloc>224</yloc>
+      <xloc>640</xloc>
+      <yloc>368</yloc>
     </GUI>
   </transform>
   <transform_error_handling>
     <error>
-      <source_transform>Insert / update</source_transform>
-      <target_transform>Change job status on error</target_transform>
+      <source_transform>insert_or_update_RD</source_transform>
+      <target_transform>change_job_status_on_error_RD</target_transform>
       <is_enabled>Y</is_enabled>
       <nr_valuename/>
       <descriptions_valuename>error_description</descriptions_valuename>
diff --git a/mappings/info_recruits/raw_data/restriction_document/parallel/restriction_document_flow_repeat.hpl b/mappings/info_recruits/raw_data/restriction_document/parallel/restriction_document_flow_repeat.hpl
index b74cd46..8ca5fab 100644
--- a/mappings/info_recruits/raw_data/restriction_document/parallel/restriction_document_flow_repeat.hpl
+++ b/mappings/info_recruits/raw_data/restriction_document/parallel/restriction_document_flow_repeat.hpl
@@ -21,53 +21,53 @@
   </notepads>
   <order>
     <hop>
-      <from>Create job execution record</from>
-      <to>Table input</to>
+      <from>create_job_execution_record_RD</from>
+      <to>input_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table input</from>
-      <to>Identify last row in a stream</to>
+      <from>filter_rows_RD</from>
+      <to>change_job_status_on_success_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Filter rows</from>
-      <to>Change job status on success</to>
+      <from>detect_empty_stream_RD</from>
+      <to>change_job_status_on_success_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Detect empty stream</from>
-      <to>Change job status on success</to>
+      <from>change_job_status_on_error_RD</from>
+      <to>abort_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Change job status on error</from>
-      <to>Abort</to>
+      <from>insert_or_update_RD</from>
+      <to>detect_empty_stream_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Identify last row in a stream</from>
-      <to>Insert / update</to>
+      <from>insert_or_update_RD</from>
+      <to>change_job_status_on_error_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Insert / update</from>
-      <to>Filter rows</to>
+      <from>insert_or_update_RD</from>
+      <to>identify_last_row_in_a_stream_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Insert / update</from>
-      <to>Detect empty stream</to>
+      <from>identify_last_row_in_a_stream_RD</from>
+      <to>filter_rows_RD</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Insert / update</from>
-      <to>Change job status on error</to>
+      <from>input_RD</from>
+      <to>insert_or_update_RD</to>
       <enabled>Y</enabled>
     </hop>
   </order>
   <transform>
-    <name>Abort</name>
+    <name>abort_RD</name>
     <type>Abort</type>
     <description/>
     <distribute>Y</distribute>
@@ -83,11 +83,11 @@
     <attributes/>
     <GUI>
       <xloc>1248</xloc>
-      <yloc>400</yloc>
+      <yloc>656</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Change job status on error</name>
+    <name>change_job_status_on_error_RD</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -118,11 +118,11 @@ and recruitment_id = '${IDM_ID}';
     <attributes/>
     <GUI>
       <xloc>960</xloc>
-      <yloc>400</yloc>
+      <yloc>656</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Change job status on success</name>
+    <name>change_job_status_on_success_RD</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -153,7 +153,7 @@ and recruitment_id = '${IDM_ID}';
     </GUI>
   </transform>
   <transform>
-    <name>Create job execution record</name>
+    <name>create_job_execution_record_RD</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -196,11 +196,11 @@ DO UPDATE SET
     <attributes/>
     <GUI>
       <xloc>272</xloc>
-      <yloc>208</yloc>
+      <yloc>416</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Detect empty stream</name>
+    <name>detect_empty_stream_RD</name>
     <type>DetectEmptyStream</type>
     <description/>
     <distribute>Y</distribute>
@@ -213,11 +213,11 @@ DO UPDATE SET
     <attributes/>
     <GUI>
       <xloc>1440</xloc>
-      <yloc>208</yloc>
+      <yloc>416</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Filter rows</name>
+    <name>filter_rows_RD</name>
     <type>FilterRows</type>
     <description/>
     <distribute>Y</distribute>
@@ -245,7 +245,7 @@ DO UPDATE SET
         </value>
       </condition>
     </compare>
-    <send_true_to>Change job status on success</send_true_to>
+    <send_true_to>change_job_status_on_success_RD</send_true_to>
     <attributes/>
     <GUI>
       <xloc>960</xloc>
@@ -253,7 +253,7 @@ DO UPDATE SET
     </GUI>
   </transform>
   <transform>
-    <name>Identify last row in a stream</name>
+    <name>identify_last_row_in_a_stream_RD</name>
     <type>DetectLastRow</type>
     <description/>
     <distribute>Y</distribute>
@@ -266,12 +266,39 @@ DO UPDATE SET
     <resultfieldname>last_row</resultfieldname>
     <attributes/>
     <GUI>
-      <xloc>720</xloc>
-      <yloc>208</yloc>
+      <xloc>960</xloc>
+      <yloc>224</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Insert / update</name>
+    <name>input_RD</name>
+    <type>TableInput</type>
+    <description/>
+    <distribute>N</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>postgres.subpoena</connection>
+    <execute_each_row>N</execute_each_row>
+    <sql>SELECT
+*
+FROM public.restriction_document 
+WHERE 
+    '${IDM_ID}' != ''  -- Проверка на пустую строку
+    AND vk_id = '${IDM_ID}'
+</sql>
+    <variables_active>Y</variables_active>
+    <attributes/>
+    <GUI>
+      <xloc>608</xloc>
+      <yloc>416</yloc>
+    </GUI>
+  </transform>
+  <transform>
+    <name>insert_or_update_RD</name>
     <type>InsertUpdate</type>
     <description/>
     <distribute>N</distribute>
@@ -288,11 +315,7 @@ DO UPDATE SET
         <condition>=</condition>
         <field>id</field>
         <name>id</name>
-      </key>
-      <key>
-        <condition>=</condition>
-        <field>created_at</field>
-        <name>created_at</name>
+        <name2/>
       </key>
       <schema>ervu_dashboard</schema>
       <table>restriction_document</table>
@@ -304,12 +327,12 @@ DO UPDATE SET
       <value>
         <name>subpoena_id</name>
         <rename>subpoena_id</rename>
-        <update>Y</update>
+        <update>N</update>
       </value>
       <value>
         <name>created_at</name>
         <rename>created_at</rename>
-        <update>N</update>
+        <update>Y</update>
       </value>
       <value>
         <name>updated_at</name>
@@ -367,44 +390,17 @@ DO UPDATE SET
         <update>Y</update>
       </value>
     </lookup>
-    <update_bypassed>N</update_bypassed>
+    <update_bypassed>Y</update_bypassed>
     <attributes/>
     <GUI>
       <xloc>960</xloc>
-      <yloc>208</yloc>
-    </GUI>
-  </transform>
-  <transform>
-    <name>Table input</name>
-    <type>TableInput</type>
-    <description/>
-    <distribute>N</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>postgres.subpoena</connection>
-    <execute_each_row>N</execute_each_row>
-    <sql>SELECT
-*
-FROM public.restriction_document 
-WHERE 
-    '${IDM_ID}' != ''  -- Проверка на пустую строку
-    AND vk_id = '${IDM_ID}'
-</sql>
-    <variables_active>Y</variables_active>
-    <attributes/>
-    <GUI>
-      <xloc>480</xloc>
-      <yloc>208</yloc>
+      <yloc>416</yloc>
     </GUI>
   </transform>
   <transform_error_handling>
     <error>
-      <source_transform>Insert / update</source_transform>
-      <target_transform>Change job status on error</target_transform>
+      <source_transform>insert_or_update_RD</source_transform>
+      <target_transform>change_job_status_on_error_RD</target_transform>
       <is_enabled>Y</is_enabled>
       <nr_valuename/>
       <descriptions_valuename>error_description</descriptions_valuename>
diff --git a/mappings/info_recruits/raw_data/restriction_document/recruitment_five_flow_delta.hpl b/mappings/info_recruits/raw_data/restriction_document/recruitment_five_flow_delta.hpl
index 00e079c..ba6d13f 100644
--- a/mappings/info_recruits/raw_data/restriction_document/recruitment_five_flow_delta.hpl
+++ b/mappings/info_recruits/raw_data/restriction_document/recruitment_five_flow_delta.hpl
@@ -21,33 +21,111 @@
   </notepads>
   <order>
     <hop>
-      <from>Table input</from>
-      <to>restriction_document_flow_delta.hpl</to>
+      <from>max_update_date_from_restriction_document</from>
+      <to>failed_restriction_document_idm_ids_on_delta</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table input</from>
+      <from>max_update_date_from_restriction_document</from>
+      <to>updated_idm_ids_from_source_restriction_document</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>Sort rows</from>
+      <to>restriction_document_flow_delta.hpl 1</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>Sort rows</from>
       <to>restriction_document_flow_delta.hpl 2</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table input</from>
+      <from>Sort rows</from>
       <to>restriction_document_flow_delta.hpl 3</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table input</from>
+      <from>Sort rows</from>
       <to>restriction_document_flow_delta.hpl 4</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table input</from>
+      <from>Sort rows</from>
       <to>restriction_document_flow_delta.hpl 5</to>
       <enabled>Y</enabled>
     </hop>
+    <hop>
+      <from>updated_idm_ids_from_source_restriction_document</from>
+      <to>Append streams</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>failed_restriction_document_idm_ids_on_delta</from>
+      <to>Append streams</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>Append streams</from>
+      <to>Sort rows</to>
+      <enabled>Y</enabled>
+    </hop>
   </order>
   <transform>
-    <name>Table input</name>
+    <name>Append streams</name>
+    <type>Append</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <head_name>updated_idm_ids_from_source_restriction_document</head_name>
+    <tail_name>failed_restriction_document_idm_ids_on_delta</tail_name>
+    <attributes/>
+    <GUI>
+      <xloc>592</xloc>
+      <yloc>800</yloc>
+    </GUI>
+  </transform>
+  <transform>
+    <name>Sort rows</name>
+    <type>SortRows</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <directory>${java.io.tmpdir}</directory>
+    <prefix>out</prefix>
+    <sort_size>100000</sort_size>
+    <free_memory/>
+    <compress>N</compress>
+    <compress_variable/>
+    <unique_rows>Y</unique_rows>
+    <fields>
+      <field>
+        <name>recruitment_id</name>
+        <ascending>Y</ascending>
+        <case_sensitive>N</case_sensitive>
+        <collator_enabled>N</collator_enabled>
+        <collator_strength>0</collator_strength>
+        <presorted>N</presorted>
+      </field>
+    </fields>
+    <attributes/>
+    <GUI>
+      <xloc>768</xloc>
+      <yloc>800</yloc>
+    </GUI>
+  </transform>
+  <transform>
+    <name>failed_restriction_document_idm_ids_on_delta</name>
     <type>TableInput</type>
     <description/>
     <distribute>Y</distribute>
@@ -60,36 +138,46 @@
     <connection>ervu-dashboard</connection>
     <execute_each_row>N</execute_each_row>
     <limit>0</limit>
-    <sql>WITH mud AS (SELECT recruitment_id,
-                    MAX(execution_datetime) AS max_upd_date
-             FROM etl.job_execution
-             WHERE job_name = '${JOB_NAME}'
-               AND status IN ('SUCCESS', 'DELTA_SUCCESS')
-             GROUP BY recruitment_id)
-SELECT r.idm_id
-FROM ervu_dashboard.recruitment r
-         JOIN mud ON mud.recruitment_id = r.idm_id
-         JOIN recruits_info ri
-              ON COALESCE(ri.current_recruitment_id, ri.target_recruitment_id) = r.idm_id
-                  AND ri.updated_at > mud.max_upd_date
-
-union
-
-select r2.idm_id
-from ervu_dashboard.recruitment r2
+    <lookup>max_update_date_from_restriction_document</lookup>
+    <sql>select r.idm_id as recruitment_id,
+	? as max_update_date
+from ervu_dashboard.recruitment r
          join etl.job_execution je
-              on r2.idm_id = je.recruitment_id
+              on r.idm_id = je.recruitment_id
 where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
   and je.job_name = '${JOB_NAME}';</sql>
     <variables_active>Y</variables_active>
     <attributes/>
     <GUI>
       <xloc>352</xloc>
-      <yloc>288</yloc>
+      <yloc>1008</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>restriction_document_flow_delta.hpl</name>
+    <name>max_update_date_from_restriction_document</name>
+    <type>TableInput</type>
+    <description/>
+    <distribute>N</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>ervu-dashboard</connection>
+    <execute_each_row>N</execute_each_row>
+    <limit>0</limit>
+    <sql>select max(updated_at) as max_update_date
+    from ervu_dashboard.restriction_document;</sql>
+    <variables_active>N</variables_active>
+    <attributes/>
+    <GUI>
+      <xloc>352</xloc>
+      <yloc>800</yloc>
+    </GUI>
+  </transform>
+  <transform>
+    <name>restriction_document_flow_delta.hpl 1</name>
     <type>PipelineExecutor</type>
     <description/>
     <distribute>Y</distribute>
@@ -109,7 +197,12 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <parameters>
       <variable_mapping>
         <variable>IDM_ID</variable>
-        <field>idm_id</field>
+        <field>recruitment_id</field>
+        <input/>
+      </variable_mapping>
+      <variable_mapping>
+        <variable>MAX_UPDATE_DATE</variable>
+        <field>max_update_date</field>
         <input/>
       </variable_mapping>
       <inherit_all_vars>Y</inherit_all_vars>
@@ -135,8 +228,8 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <executors_output_transform/>
     <attributes/>
     <GUI>
-      <xloc>656</xloc>
-      <yloc>128</yloc>
+      <xloc>928</xloc>
+      <yloc>672</yloc>
     </GUI>
   </transform>
   <transform>
@@ -160,7 +253,12 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <parameters>
       <variable_mapping>
         <variable>IDM_ID</variable>
-        <field>idm_id</field>
+        <field>recruitment_id</field>
+        <input/>
+      </variable_mapping>
+      <variable_mapping>
+        <variable>MAX_UPDATE_DATE</variable>
+        <field>max_update_date</field>
         <input/>
       </variable_mapping>
       <inherit_all_vars>Y</inherit_all_vars>
@@ -186,8 +284,8 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <executors_output_transform/>
     <attributes/>
     <GUI>
-      <xloc>656</xloc>
-      <yloc>208</yloc>
+      <xloc>1024</xloc>
+      <yloc>752</yloc>
     </GUI>
   </transform>
   <transform>
@@ -211,7 +309,12 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <parameters>
       <variable_mapping>
         <variable>IDM_ID</variable>
-        <field>idm_id</field>
+        <field>recruitment_id</field>
+        <input/>
+      </variable_mapping>
+      <variable_mapping>
+        <variable>MAX_UPDATE_DATE</variable>
+        <field>max_update_date</field>
         <input/>
       </variable_mapping>
       <inherit_all_vars>Y</inherit_all_vars>
@@ -237,8 +340,8 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <executors_output_transform/>
     <attributes/>
     <GUI>
-      <xloc>656</xloc>
-      <yloc>288</yloc>
+      <xloc>1024</xloc>
+      <yloc>848</yloc>
     </GUI>
   </transform>
   <transform>
@@ -262,7 +365,12 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <parameters>
       <variable_mapping>
         <variable>IDM_ID</variable>
-        <field>idm_id</field>
+        <field>recruitment_id</field>
+        <input/>
+      </variable_mapping>
+      <variable_mapping>
+        <variable>MAX_UPDATE_DATE</variable>
+        <field>max_update_date</field>
         <input/>
       </variable_mapping>
       <inherit_all_vars>Y</inherit_all_vars>
@@ -288,8 +396,8 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <executors_output_transform/>
     <attributes/>
     <GUI>
-      <xloc>656</xloc>
-      <yloc>368</yloc>
+      <xloc>1024</xloc>
+      <yloc>944</yloc>
     </GUI>
   </transform>
   <transform>
@@ -313,7 +421,12 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <parameters>
       <variable_mapping>
         <variable>IDM_ID</variable>
-        <field>idm_id</field>
+        <field>recruitment_id</field>
+        <input/>
+      </variable_mapping>
+      <variable_mapping>
+        <variable>MAX_UPDATE_DATE</variable>
+        <field>max_update_date</field>
         <input/>
       </variable_mapping>
       <inherit_all_vars>Y</inherit_all_vars>
@@ -339,8 +452,36 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <executors_output_transform/>
     <attributes/>
     <GUI>
-      <xloc>656</xloc>
-      <yloc>448</yloc>
+      <xloc>976</xloc>
+      <yloc>1040</yloc>
+    </GUI>
+  </transform>
+  <transform>
+    <name>updated_idm_ids_from_source_restriction_document</name>
+    <type>TableInput</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>postgres.subpoena</connection>
+    <execute_each_row>N</execute_each_row>
+    <limit>0</limit>
+    <lookup>max_update_date_from_restriction_document</lookup>
+    <sql>WITH max_update_date(val) AS (SELECT CAST(? AS timestamp))
+SELECT DISTINCT ra.vk_id as recruitment_id,
+          mud.val as max_update_date
+FROM public.restriction_document ra
+JOIN max_update_date mud ON TRUE
+WHERE (mud.val IS NULL OR ra.updated_at > mud.val);</sql>
+    <variables_active>Y</variables_active>
+    <attributes/>
+    <GUI>
+      <xloc>352</xloc>
+      <yloc>608</yloc>
     </GUI>
   </transform>
   <transform_error_handling>
diff --git a/mappings/info_recruits/raw_data/restriction_document_item/parallel/restriction_document_item_flow.hpl b/mappings/info_recruits/raw_data/restriction_document_item/parallel/restriction_document_item_flow.hpl
index 737c73c..288fafb 100644
--- a/mappings/info_recruits/raw_data/restriction_document_item/parallel/restriction_document_item_flow.hpl
+++ b/mappings/info_recruits/raw_data/restriction_document_item/parallel/restriction_document_item_flow.hpl
@@ -21,73 +21,68 @@
   </notepads>
   <order>
     <hop>
-      <from>Create job execution record</from>
-      <to>Table input</to>
+      <from>create_job_execution_record_RDI</from>
+      <to>table_input_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Filter rows</from>
-      <to>Change job status on success</to>
+      <from>filter_rows_RDI</from>
+      <to>change_job_status_on_success_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Detect empty stream</from>
-      <to>Change job status on success</to>
+      <from>detect_empty_stream_RDI</from>
+      <to>change_job_status_on_success_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Change job status on error</from>
-      <to>Abort</to>
+      <from>change_job_status_on_error_RDI</from>
+      <to>abort_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table output</from>
-      <to>Change job status on error</to>
+      <from>table_output_RDI</from>
+      <to>change_job_status_on_error_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Update</from>
-      <to>Change job status on error</to>
+      <from>update_flags_RDI</from>
+      <to>change_job_status_on_error_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table input</from>
-      <to>Identify last row in a stream</to>
+      <from>group_by_RDI</from>
+      <to>update_flags_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Identify last row in a stream</from>
-      <to>Table output</to>
+      <from>table_output_RDI</from>
+      <to>identify_last_row_in_a_stream_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Identify last row in a stream</from>
-      <to>Detect empty stream</to>
+      <from>identify_last_row_in_a_stream_RDI</from>
+      <to>filter_rows_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Identify last row in a stream</from>
-      <to>sort_by_recruit_id</to>
+      <from>table_input_RDI</from>
+      <to>detect_empty_stream_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>sort_by_recruit_id</from>
-      <to>Update</to>
+      <from>table_input_RDI</from>
+      <to>group_by_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table output</from>
-      <to>Block until transforms finish</to>
-      <enabled>Y</enabled>
-    </hop>
-    <hop>
-      <from>Block until transforms finish</from>
-      <to>Filter rows</to>
+      <from>table_input_RDI</from>
+      <to>table_output_RDI</to>
       <enabled>Y</enabled>
     </hop>
   </order>
   <transform>
-    <name>Abort</name>
+    <name>abort_RDI</name>
     <type>Abort</type>
     <description/>
     <distribute>Y</distribute>
@@ -99,37 +94,16 @@
     </partitioning>
     <abort_option>ABORT_WITH_ERROR</abort_option>
     <always_log_rows>Y</always_log_rows>
+    <message/>
     <row_threshold>0</row_threshold>
     <attributes/>
     <GUI>
       <xloc>1360</xloc>
-      <yloc>496</yloc>
+      <yloc>752</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>1152</xloc>
-      <yloc>320</yloc>
-    </GUI>
-  </transform>
-  <transform>
-    <name>Change job status on error</name>
+    <name>change_job_status_on_error_RDI</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -145,8 +119,11 @@
       </argument>
     </arguments>
     <connection>ervu-dashboard</connection>
+    <delete_field/>
     <execute_each_row>Y</execute_each_row>
+    <insert_field/>
     <quoteString>N</quoteString>
+    <read_field/>
     <replace_variables>Y</replace_variables>
     <set_params>Y</set_params>
     <single_statement>N</single_statement>
@@ -157,14 +134,15 @@ WHERE job_name = '${JOB_NAME}'
 and recruitment_id = '${IDM_ID}';
 
 </sql>
+    <update_field/>
     <attributes/>
     <GUI>
-      <xloc>1168</xloc>
-      <yloc>496</yloc>
+      <xloc>1008</xloc>
+      <yloc>752</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Change job status on success</name>
+    <name>change_job_status_on_success_RDI</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -177,8 +155,11 @@ and recruitment_id = '${IDM_ID}';
     <arguments>
 </arguments>
     <connection>ervu-dashboard</connection>
+    <delete_field/>
     <execute_each_row>Y</execute_each_row>
+    <insert_field/>
     <quoteString>N</quoteString>
+    <read_field/>
     <replace_variables>Y</replace_variables>
     <set_params>N</set_params>
     <single_statement>N</single_statement>
@@ -188,14 +169,15 @@ WHERE job_name = '${JOB_NAME}'
 and recruitment_id = '${IDM_ID}';
 
 </sql>
+    <update_field/>
     <attributes/>
     <GUI>
-      <xloc>1344</xloc>
+      <xloc>1424</xloc>
       <yloc>176</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Create job execution record</name>
+    <name>create_job_execution_record_RDI</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -208,8 +190,11 @@ and recruitment_id = '${IDM_ID}';
     <arguments>
 </arguments>
     <connection>ervu-dashboard</connection>
+    <delete_field/>
     <execute_each_row>N</execute_each_row>
+    <insert_field/>
     <quoteString>N</quoteString>
+    <read_field/>
     <replace_variables>Y</replace_variables>
     <set_params>N</set_params>
     <single_statement>N</single_statement>
@@ -217,14 +202,15 @@ and recruitment_id = '${IDM_ID}';
 VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}');
 
 </sql>
+    <update_field/>
     <attributes/>
     <GUI>
       <xloc>288</xloc>
-      <yloc>320</yloc>
+      <yloc>400</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Detect empty stream</name>
+    <name>detect_empty_stream_RDI</name>
     <type>DetectEmptyStream</type>
     <description/>
     <distribute>Y</distribute>
@@ -241,7 +227,7 @@ VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}');
     </GUI>
   </transform>
   <transform>
-    <name>Filter rows</name>
+    <name>filter_rows_RDI</name>
     <type>FilterRows</type>
     <description/>
     <distribute>Y</distribute>
@@ -269,15 +255,52 @@ VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}');
         </value>
       </condition>
     </compare>
-    <send_true_to>Change job status on success</send_true_to>
+    <send_true_to>change_job_status_on_success_RDI</send_true_to>
     <attributes/>
     <GUI>
-      <xloc>1344</xloc>
-      <yloc>320</yloc>
+      <xloc>1424</xloc>
+      <yloc>400</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Identify last row in a stream</name>
+    <name>group_by_RDI</name>
+    <type>GroupBy</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <add_linenr>N</add_linenr>
+    <all_rows>N</all_rows>
+    <directory>${java.io.tmpdir}</directory>
+    <fields>
+      <field>
+        <aggregate>has_active_temporary_measure</aggregate>
+        <subject>has_active_temporary_measure</subject>
+        <type>MAX</type>
+        <valuefield/>
+      </field>
+    </fields>
+    <give_back_row>N</give_back_row>
+    <group>
+      <field>
+        <name>recruit_id</name>
+      </field>
+    </group>
+    <ignore_aggregate>N</ignore_aggregate>
+    <linenr_fieldname/>
+    <prefix>grp</prefix>
+    <attributes/>
+    <GUI>
+      <xloc>704</xloc>
+      <yloc>576</yloc>
+    </GUI>
+  </transform>
+  <transform>
+    <name>identify_last_row_in_a_stream_RDI</name>
     <type>DetectLastRow</type>
     <description/>
     <distribute>N</distribute>
@@ -290,15 +313,15 @@ VALUES (DEFAULT, '${JOB_NAME}', 'PROCESSING', DEFAULT, null, '${IDM_ID}');
     <resultfieldname>last_row</resultfieldname>
     <attributes/>
     <GUI>
-      <xloc>704</xloc>
-      <yloc>320</yloc>
+      <xloc>1200</xloc>
+      <yloc>400</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Table input</name>
+    <name>table_input_RDI</name>
     <type>TableInput</type>
     <description/>
-    <distribute>Y</distribute>
+    <distribute>N</distribute>
     <custom_distribution/>
     <copies>1</copies>
     <partitioning>
@@ -323,16 +346,16 @@ s.id = rd.subpoena_id
 WHERE 
     '${IDM_ID}' != ''  -- Проверка на пустую строку
     AND rd.vk_id = '${IDM_ID}'
-</sql>
+ORDER BY s.recruit_id</sql>
     <variables_active>Y</variables_active>
     <attributes/>
     <GUI>
-      <xloc>496</xloc>
-      <yloc>320</yloc>
+      <xloc>704</xloc>
+      <yloc>400</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Table output</name>
+    <name>table_output_RDI</name>
     <type>TableOutput</type>
     <description/>
     <distribute>Y</distribute>
@@ -410,23 +433,26 @@ WHERE
     <only_when_have_rows>N</only_when_have_rows>
     <partitioning_daily>N</partitioning_daily>
     <partitioning_enabled>N</partitioning_enabled>
+    <partitioning_field/>
     <partitioning_monthly>Y</partitioning_monthly>
+    <return_field/>
     <return_keys>N</return_keys>
     <schema>ervu_dashboard</schema>
     <specify_fields>Y</specify_fields>
     <table>restriction_document_item</table>
+    <tablename_field/>
     <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>928</xloc>
-      <yloc>320</yloc>
+      <xloc>1008</xloc>
+      <yloc>400</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Update</name>
+    <name>update_flags_RDI</name>
     <type>Update</type>
     <description/>
     <distribute>N</distribute>
@@ -439,11 +465,13 @@ WHERE
     <commit>10000</commit>
     <connection>ervu-dashboard</connection>
     <error_ignored>Y</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>
@@ -455,47 +483,15 @@ WHERE
     <skip_lookup>N</skip_lookup>
     <use_batch>Y</use_batch>
     <attributes/>
-    <GUI>
-      <xloc>928</xloc>
-      <yloc>496</yloc>
-    </GUI>
-  </transform>
-  <transform>
-    <name>sort_by_recruit_id</name>
-    <type>SortRows</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <compress>N</compress>
-    <directory>${java.io.tmpdir}</directory>
-    <fields>
-      <field>
-        <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_prefix>srt</sort_prefix>
-    <sort_size>1000000</sort_size>
-    <unique_rows>Y</unique_rows>
-    <attributes/>
     <GUI>
       <xloc>704</xloc>
-      <yloc>496</yloc>
+      <yloc>752</yloc>
     </GUI>
   </transform>
   <transform_error_handling>
     <error>
-      <source_transform>Table output</source_transform>
-      <target_transform>Change job status on error</target_transform>
+      <source_transform>table_output_RDI</source_transform>
+      <target_transform>change_job_status_on_error_RDI</target_transform>
       <is_enabled>Y</is_enabled>
       <nr_valuename/>
       <descriptions_valuename>error_description</descriptions_valuename>
@@ -506,8 +502,8 @@ WHERE
       <min_pct_rows/>
     </error>
     <error>
-      <source_transform>Update</source_transform>
-      <target_transform>Change job status on error</target_transform>
+      <source_transform>update_flags_RDI</source_transform>
+      <target_transform>change_job_status_on_error_RDI</target_transform>
       <is_enabled>Y</is_enabled>
       <nr_valuename/>
       <descriptions_valuename>error_description</descriptions_valuename>
diff --git a/mappings/info_recruits/raw_data/restriction_document_item/parallel/restriction_document_item_flow_delta.hpl b/mappings/info_recruits/raw_data/restriction_document_item/parallel/restriction_document_item_flow_delta.hpl
index f8cdb0f..cc8da14 100644
--- a/mappings/info_recruits/raw_data/restriction_document_item/parallel/restriction_document_item_flow_delta.hpl
+++ b/mappings/info_recruits/raw_data/restriction_document_item/parallel/restriction_document_item_flow_delta.hpl
@@ -21,73 +21,68 @@
   </notepads>
   <order>
     <hop>
-      <from>Create job execution record</from>
-      <to>Table input</to>
+      <from>create_job_execution_record_RDI</from>
+      <to>table_input_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Detect empty stream</from>
-      <to>Change job status on success</to>
+      <from>detect_empty_stream_RDI</from>
+      <to>change_job_status_on_success_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Filter rows</from>
-      <to>Change job status on success</to>
+      <from>filter_rows_RDI</from>
+      <to>change_job_status_on_success_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Change job status on error</from>
-      <to>Abort</to>
+      <from>change_job_status_on_error_RDI</from>
+      <to>abort_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Insert / update</from>
-      <to>Change job status on error</to>
+      <from>insert_or_update_RDI</from>
+      <to>change_job_status_on_error_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Update</from>
-      <to>Change job status on error</to>
+      <from>update_flags_RDI</from>
+      <to>change_job_status_on_error_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table input</from>
-      <to>Identify last row in a stream</to>
+      <from>insert_or_update_RDI</from>
+      <to>identify_last_row_in_a_stream_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Identify last row in a stream</from>
-      <to>Insert / update</to>
+      <from>identify_last_row_in_a_stream_RDI</from>
+      <to>filter_rows_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Identify last row in a stream</from>
-      <to>Detect empty stream</to>
+      <from>table_input_RDI</from>
+      <to>insert_or_update_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Insert / update</from>
-      <to>Block until transforms finish</to>
+      <from>table_input_RDI</from>
+      <to>detect_empty_stream_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Block until transforms finish</from>
-      <to>Filter rows</to>
+      <from>table_input_RDI</from>
+      <to>group_by_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Identify last row in a stream</from>
-      <to>sort_by_recruit_id</to>
-      <enabled>Y</enabled>
-    </hop>
-    <hop>
-      <from>sort_by_recruit_id</from>
-      <to>Update</to>
+      <from>group_by_RDI</from>
+      <to>update_flags_RDI</to>
       <enabled>Y</enabled>
     </hop>
   </order>
   <transform>
-    <name>Abort</name>
+    <name>abort_RDI</name>
     <type>Abort</type>
     <description/>
     <distribute>Y</distribute>
@@ -99,37 +94,16 @@
     </partitioning>
     <abort_option>ABORT_WITH_ERROR</abort_option>
     <always_log_rows>Y</always_log_rows>
+    <message/>
     <row_threshold>0</row_threshold>
     <attributes/>
     <GUI>
-      <xloc>1408</xloc>
-      <yloc>368</yloc>
+      <xloc>1488</xloc>
+      <yloc>784</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>1264</xloc>
-      <yloc>224</yloc>
-    </GUI>
-  </transform>
-  <transform>
-    <name>Change job status on error</name>
+    <name>change_job_status_on_error_RDI</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -145,8 +119,11 @@
       </argument>
     </arguments>
     <connection>ervu-dashboard</connection>
+    <delete_field/>
     <execute_each_row>Y</execute_each_row>
+    <insert_field/>
     <quoteString>N</quoteString>
+    <read_field/>
     <replace_variables>Y</replace_variables>
     <set_params>Y</set_params>
     <single_statement>N</single_statement>
@@ -157,14 +134,15 @@ WHERE job_name = '${JOB_NAME}'
 and recruitment_id = '${IDM_ID}';
 
 </sql>
+    <update_field/>
     <attributes/>
     <GUI>
-      <xloc>1232</xloc>
-      <yloc>368</yloc>
+      <xloc>1152</xloc>
+      <yloc>784</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Change job status on success</name>
+    <name>change_job_status_on_success_RDI</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -177,8 +155,11 @@ and recruitment_id = '${IDM_ID}';
     <arguments>
 </arguments>
     <connection>ervu-dashboard</connection>
+    <delete_field/>
     <execute_each_row>Y</execute_each_row>
+    <insert_field/>
     <quoteString>N</quoteString>
+    <read_field/>
     <replace_variables>Y</replace_variables>
     <set_params>N</set_params>
     <single_statement>N</single_statement>
@@ -188,14 +169,15 @@ WHERE job_name = '${JOB_NAME}'
 and recruitment_id = '${IDM_ID}';
 
 </sql>
+    <update_field/>
     <attributes/>
     <GUI>
-      <xloc>1472</xloc>
-      <yloc>80</yloc>
+      <xloc>1552</xloc>
+      <yloc>304</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Create job execution record</name>
+    <name>create_job_execution_record_RDI</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -208,8 +190,11 @@ and recruitment_id = '${IDM_ID}';
     <arguments>
 </arguments>
     <connection>ervu-dashboard</connection>
+    <delete_field/>
     <execute_each_row>N</execute_each_row>
+    <insert_field/>
     <quoteString>N</quoteString>
+    <read_field/>
     <replace_variables>Y</replace_variables>
     <set_params>N</set_params>
     <single_statement>N</single_statement>
@@ -220,14 +205,15 @@ SET
     error_description = NULL
 where job_name = '${JOB_NAME}'
 and recruitment_id = '${IDM_ID}';</sql>
+    <update_field/>
     <attributes/>
     <GUI>
-      <xloc>336</xloc>
-      <yloc>224</yloc>
+      <xloc>320</xloc>
+      <yloc>576</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Detect empty stream</name>
+    <name>detect_empty_stream_RDI</name>
     <type>DetectEmptyStream</type>
     <description/>
     <distribute>Y</distribute>
@@ -239,12 +225,12 @@ and recruitment_id = '${IDM_ID}';</sql>
     </partitioning>
     <attributes/>
     <GUI>
-      <xloc>768</xloc>
-      <yloc>80</yloc>
+      <xloc>752</xloc>
+      <yloc>304</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Filter rows</name>
+    <name>filter_rows_RDI</name>
     <type>FilterRows</type>
     <description/>
     <distribute>Y</distribute>
@@ -272,15 +258,52 @@ and recruitment_id = '${IDM_ID}';</sql>
         </value>
       </condition>
     </compare>
-    <send_true_to>Change job status on success</send_true_to>
+    <send_true_to>change_job_status_on_success_RDI</send_true_to>
     <attributes/>
     <GUI>
-      <xloc>1472</xloc>
-      <yloc>224</yloc>
+      <xloc>1552</xloc>
+      <yloc>576</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Identify last row in a stream</name>
+    <name>group_by_RDI</name>
+    <type>GroupBy</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <add_linenr>N</add_linenr>
+    <all_rows>N</all_rows>
+    <directory>${java.io.tmpdir}</directory>
+    <fields>
+      <field>
+        <aggregate>has_active_temporary_measure</aggregate>
+        <subject>has_active_temporary_measure</subject>
+        <type>MAX</type>
+        <valuefield/>
+      </field>
+    </fields>
+    <give_back_row>N</give_back_row>
+    <group>
+      <field>
+        <name>recruit_id</name>
+      </field>
+    </group>
+    <ignore_aggregate>N</ignore_aggregate>
+    <linenr_fieldname/>
+    <prefix>grp</prefix>
+    <attributes/>
+    <GUI>
+      <xloc>752</xloc>
+      <yloc>784</yloc>
+    </GUI>
+  </transform>
+  <transform>
+    <name>identify_last_row_in_a_stream_RDI</name>
     <type>DetectLastRow</type>
     <description/>
     <distribute>N</distribute>
@@ -293,12 +316,12 @@ and recruitment_id = '${IDM_ID}';</sql>
     <resultfieldname>last_row</resultfieldname>
     <attributes/>
     <GUI>
-      <xloc>768</xloc>
-      <yloc>224</yloc>
+      <xloc>1344</xloc>
+      <yloc>576</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Insert / update</name>
+    <name>insert_or_update_RDI</name>
     <type>InsertUpdate</type>
     <description/>
     <distribute>Y</distribute>
@@ -315,11 +338,13 @@ and recruitment_id = '${IDM_ID}';</sql>
         <condition>=</condition>
         <field>id</field>
         <name>id</name>
+        <name2/>
       </key>
       <key>
         <condition>=</condition>
         <field>created_at</field>
         <name>created_at</name>
+        <name2/>
       </key>
       <schema>ervu_dashboard</schema>
       <table>restriction_document_item</table>
@@ -402,23 +427,24 @@ and recruitment_id = '${IDM_ID}';</sql>
     <update_bypassed>N</update_bypassed>
     <attributes/>
     <GUI>
-      <xloc>992</xloc>
-      <yloc>224</yloc>
+      <xloc>1152</xloc>
+      <yloc>576</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Table input</name>
+    <name>table_input_RDI</name>
     <type>TableInput</type>
     <description/>
-    <distribute>Y</distribute>
+    <distribute>N</distribute>
     <custom_distribution/>
     <copies>1</copies>
     <partitioning>
       <method>none</method>
       <schema_name/>
     </partitioning>
-    <connection>ervu_person_registry</connection>
+    <connection>postgres.subpoena</connection>
     <execute_each_row>N</execute_each_row>
+    <limit/>
     <sql>select
 s.recruit_id,
 CASE
@@ -434,16 +460,17 @@ s.id = rd.subpoena_id
 WHERE 
     '${IDM_ID}' != ''  -- Проверка на пустую строку
     AND rd.vk_id = '${IDM_ID}'
-    AND rdi.updated_at >= '${M_RDI_UP_DATE}'::timestamp</sql>
+    AND rdi.updated_at >= '${MAX_UPDATE_DATE}'::timestamp
+ORDER BY s.recruit_id</sql>
     <variables_active>Y</variables_active>
     <attributes/>
     <GUI>
-      <xloc>544</xloc>
-      <yloc>224</yloc>
+      <xloc>752</xloc>
+      <yloc>576</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Update</name>
+    <name>update_flags_RDI</name>
     <type>Update</type>
     <description/>
     <distribute>N</distribute>
@@ -456,16 +483,19 @@ WHERE
     <commit>10000</commit>
     <connection>ervu-dashboard</connection>
     <error_ignored>Y</error_ignored>
+    <ignore_flag_field/>
     <lookup>
       <key>
         <condition>=</condition>
         <field>recruit_id</field>
         <name>recruit_id</name>
+        <name2/>
       </key>
       <key>
         <condition>&lt;></condition>
         <field>has_active_temporary_measure</field>
         <name>has_active_temporary_measure</name>
+        <name2/>
       </key>
       <schema>ervu_dashboard</schema>
       <table>citizen</table>
@@ -478,46 +508,14 @@ WHERE
     <use_batch>Y</use_batch>
     <attributes/>
     <GUI>
-      <xloc>992</xloc>
-      <yloc>368</yloc>
-    </GUI>
-  </transform>
-  <transform>
-    <name>sort_by_recruit_id</name>
-    <type>SortRows</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <compress>N</compress>
-    <directory>${java.io.tmpdir}</directory>
-    <fields>
-      <field>
-        <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_prefix>srt</sort_prefix>
-    <sort_size>1000000</sort_size>
-    <unique_rows>Y</unique_rows>
-    <attributes/>
-    <GUI>
-      <xloc>768</xloc>
-      <yloc>368</yloc>
+      <xloc>960</xloc>
+      <yloc>784</yloc>
     </GUI>
   </transform>
   <transform_error_handling>
     <error>
-      <source_transform>Insert / update</source_transform>
-      <target_transform>Change job status on error</target_transform>
+      <source_transform>insert_or_update_RDI</source_transform>
+      <target_transform>change_job_status_on_error_RDI</target_transform>
       <is_enabled>Y</is_enabled>
       <nr_valuename/>
       <descriptions_valuename>error_description</descriptions_valuename>
@@ -528,8 +526,8 @@ WHERE
       <min_pct_rows/>
     </error>
     <error>
-      <source_transform>Update</source_transform>
-      <target_transform>Change job status on error</target_transform>
+      <source_transform>update_flags_RDI</source_transform>
+      <target_transform>change_job_status_on_error_RDI</target_transform>
       <is_enabled>Y</is_enabled>
       <nr_valuename/>
       <descriptions_valuename>error_description</descriptions_valuename>
diff --git a/mappings/info_recruits/raw_data/restriction_document_item/parallel/restriction_document_item_flow_repeat.hpl b/mappings/info_recruits/raw_data/restriction_document_item/parallel/restriction_document_item_flow_repeat.hpl
index efddae3..f1b8766 100644
--- a/mappings/info_recruits/raw_data/restriction_document_item/parallel/restriction_document_item_flow_repeat.hpl
+++ b/mappings/info_recruits/raw_data/restriction_document_item/parallel/restriction_document_item_flow_repeat.hpl
@@ -21,73 +21,68 @@
   </notepads>
   <order>
     <hop>
-      <from>Create job execution record</from>
-      <to>Table input</to>
+      <from>create_job_execution_record_RDI</from>
+      <to>table_input_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Filter rows</from>
-      <to>Change job status on success</to>
+      <from>filter_rows_RDI</from>
+      <to>change_job_status_on_success_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Detect empty stream</from>
-      <to>Change job status on success</to>
+      <from>detect_empty_stream_RDI</from>
+      <to>change_job_status_on_success_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Change job status on error</from>
-      <to>Abort</to>
+      <from>change_job_status_on_error_RDI</from>
+      <to>abort_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Insert / update</from>
-      <to>Change job status on error</to>
+      <from>insert_or_update_RDI</from>
+      <to>change_job_status_on_error_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Update</from>
-      <to>Change job status on error</to>
+      <from>update_flags_RDI</from>
+      <to>change_job_status_on_error_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table input</from>
-      <to>Identify last row in a stream</to>
+      <from>table_input_RDI</from>
+      <to>group_by_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Identify last row in a stream</from>
-      <to>Insert / update</to>
+      <from>group_by_RDI</from>
+      <to>update_flags_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Insert / update</from>
-      <to>Block until transforms finish</to>
+      <from>identify_last_row_in_a_stream_RDI</from>
+      <to>filter_rows_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Identify last row in a stream</from>
-      <to>sort_by_recruit_id</to>
+      <from>detect_empty_stream_RDI</from>
+      <to>table_input_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>sort_by_recruit_id</from>
-      <to>Update</to>
+      <from>table_input_RDI</from>
+      <to>insert_or_update_RDI</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Identify last row in a stream</from>
-      <to>Detect empty stream</to>
-      <enabled>Y</enabled>
-    </hop>
-    <hop>
-      <from>Block until transforms finish</from>
-      <to>Filter rows</to>
+      <from>insert_or_update_RDI</from>
+      <to>identify_last_row_in_a_stream_RDI</to>
       <enabled>Y</enabled>
     </hop>
   </order>
   <transform>
-    <name>Abort</name>
+    <name>abort_RDI</name>
     <type>Abort</type>
     <description/>
     <distribute>Y</distribute>
@@ -99,37 +94,16 @@
     </partitioning>
     <abort_option>ABORT_WITH_ERROR</abort_option>
     <always_log_rows>Y</always_log_rows>
+    <message/>
     <row_threshold>0</row_threshold>
     <attributes/>
     <GUI>
-      <xloc>1312</xloc>
-      <yloc>368</yloc>
+      <xloc>1440</xloc>
+      <yloc>448</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>1184</xloc>
-      <yloc>208</yloc>
-    </GUI>
-  </transform>
-  <transform>
-    <name>Change job status on error</name>
+    <name>change_job_status_on_error_RDI</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -145,8 +119,11 @@
       </argument>
     </arguments>
     <connection>ervu-dashboard</connection>
+    <delete_field/>
     <execute_each_row>Y</execute_each_row>
+    <insert_field/>
     <quoteString>N</quoteString>
+    <read_field/>
     <replace_variables>Y</replace_variables>
     <set_params>Y</set_params>
     <single_statement>N</single_statement>
@@ -157,14 +134,15 @@ WHERE job_name = '${JOB_NAME}'
 and recruitment_id = '${IDM_ID}';
 
 </sql>
+    <update_field/>
     <attributes/>
     <GUI>
-      <xloc>1136</xloc>
-      <yloc>368</yloc>
+      <xloc>1024</xloc>
+      <yloc>448</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Change job status on success</name>
+    <name>change_job_status_on_success_RDI</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -177,8 +155,11 @@ and recruitment_id = '${IDM_ID}';
     <arguments>
 </arguments>
     <connection>ervu-dashboard</connection>
+    <delete_field/>
     <execute_each_row>Y</execute_each_row>
+    <insert_field/>
     <quoteString>N</quoteString>
+    <read_field/>
     <replace_variables>Y</replace_variables>
     <set_params>N</set_params>
     <single_statement>N</single_statement>
@@ -188,6 +169,7 @@ WHERE job_name = '${JOB_NAME}'
 and recruitment_id = '${IDM_ID}';
 
 </sql>
+    <update_field/>
     <attributes/>
     <GUI>
       <xloc>1440</xloc>
@@ -195,7 +177,7 @@ and recruitment_id = '${IDM_ID}';
     </GUI>
   </transform>
   <transform>
-    <name>Create job execution record</name>
+    <name>create_job_execution_record_RDI</name>
     <type>ExecSql</type>
     <description/>
     <distribute>Y</distribute>
@@ -208,8 +190,11 @@ and recruitment_id = '${IDM_ID}';
     <arguments>
 </arguments>
     <connection>ervu-dashboard</connection>
+    <delete_field/>
     <execute_each_row>N</execute_each_row>
+    <insert_field/>
     <quoteString>N</quoteString>
+    <read_field/>
     <replace_variables>Y</replace_variables>
     <set_params>N</set_params>
     <single_statement>N</single_statement>
@@ -235,17 +220,18 @@ DO UPDATE SET
     execution_datetime = DEFAULT,
     error_description = NULL
 </sql>
+    <update_field/>
     <attributes/>
     <GUI>
       <xloc>272</xloc>
-      <yloc>208</yloc>
+      <yloc>256</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Detect empty stream</name>
+    <name>detect_empty_stream_RDI</name>
     <type>DetectEmptyStream</type>
     <description/>
-    <distribute>Y</distribute>
+    <distribute>N</distribute>
     <custom_distribution/>
     <copies>1</copies>
     <partitioning>
@@ -254,12 +240,12 @@ DO UPDATE SET
     </partitioning>
     <attributes/>
     <GUI>
-      <xloc>672</xloc>
+      <xloc>656</xloc>
       <yloc>64</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Filter rows</name>
+    <name>filter_rows_RDI</name>
     <type>FilterRows</type>
     <description/>
     <distribute>Y</distribute>
@@ -287,15 +273,52 @@ DO UPDATE SET
         </value>
       </condition>
     </compare>
-    <send_true_to>Change job status on success</send_true_to>
+    <send_true_to>change_job_status_on_success_RDI</send_true_to>
     <attributes/>
     <GUI>
       <xloc>1440</xloc>
-      <yloc>208</yloc>
+      <yloc>256</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Identify last row in a stream</name>
+    <name>group_by_RDI</name>
+    <type>GroupBy</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <add_linenr>N</add_linenr>
+    <all_rows>N</all_rows>
+    <directory>${java.io.tmpdir}</directory>
+    <fields>
+      <field>
+        <aggregate>has_active_temporary_measure</aggregate>
+        <subject>has_active_temporary_measure</subject>
+        <type>MAX</type>
+        <valuefield/>
+      </field>
+    </fields>
+    <give_back_row>N</give_back_row>
+    <group>
+      <field>
+        <name>recruit_id</name>
+      </field>
+    </group>
+    <ignore_aggregate>N</ignore_aggregate>
+    <linenr_fieldname/>
+    <prefix>grp</prefix>
+    <attributes/>
+    <GUI>
+      <xloc>656</xloc>
+      <yloc>448</yloc>
+    </GUI>
+  </transform>
+  <transform>
+    <name>identify_last_row_in_a_stream_RDI</name>
     <type>DetectLastRow</type>
     <description/>
     <distribute>N</distribute>
@@ -308,12 +331,12 @@ DO UPDATE SET
     <resultfieldname>last_row</resultfieldname>
     <attributes/>
     <GUI>
-      <xloc>672</xloc>
-      <yloc>208</yloc>
+      <xloc>1264</xloc>
+      <yloc>256</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Insert / update</name>
+    <name>insert_or_update_RDI</name>
     <type>InsertUpdate</type>
     <description/>
     <distribute>Y</distribute>
@@ -330,11 +353,13 @@ DO UPDATE SET
         <condition>=</condition>
         <field>id</field>
         <name>id</name>
+        <name2/>
       </key>
       <key>
         <condition>=</condition>
         <field>created_at</field>
         <name>created_at</name>
+        <name2/>
       </key>
       <schema>ervu_dashboard</schema>
       <table>restriction_document_item</table>
@@ -417,15 +442,15 @@ DO UPDATE SET
     <update_bypassed>N</update_bypassed>
     <attributes/>
     <GUI>
-      <xloc>912</xloc>
-      <yloc>208</yloc>
+      <xloc>1024</xloc>
+      <yloc>256</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Table input</name>
+    <name>table_input_RDI</name>
     <type>TableInput</type>
     <description/>
-    <distribute>Y</distribute>
+    <distribute>N</distribute>
     <custom_distribution/>
     <copies>1</copies>
     <partitioning>
@@ -450,16 +475,17 @@ s.id = rd.subpoena_id
 WHERE 
     '${IDM_ID}' != ''  -- Проверка на пустую строку
     AND rd.vk_id = '${IDM_ID}'
+ORDER BY s.recruit_id
 </sql>
     <variables_active>Y</variables_active>
     <attributes/>
     <GUI>
-      <xloc>480</xloc>
-      <yloc>208</yloc>
+      <xloc>656</xloc>
+      <yloc>256</yloc>
     </GUI>
   </transform>
   <transform>
-    <name>Update</name>
+    <name>update_flags_RDI</name>
     <type>Update</type>
     <description/>
     <distribute>N</distribute>
@@ -472,16 +498,19 @@ WHERE
     <commit>10000</commit>
     <connection>ervu-dashboard</connection>
     <error_ignored>Y</error_ignored>
+    <ignore_flag_field/>
     <lookup>
       <key>
         <condition>=</condition>
         <field>recruit_id</field>
         <name>recruit_id</name>
+        <name2/>
       </key>
       <key>
         <condition>&lt;></condition>
         <field>has_active_temporary_measure</field>
         <name>has_active_temporary_measure</name>
+        <name2/>
       </key>
       <schema>ervu_dashboard</schema>
       <table>citizen</table>
@@ -494,46 +523,14 @@ WHERE
     <use_batch>Y</use_batch>
     <attributes/>
     <GUI>
-      <xloc>912</xloc>
-      <yloc>368</yloc>
-    </GUI>
-  </transform>
-  <transform>
-    <name>sort_by_recruit_id</name>
-    <type>SortRows</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <compress>N</compress>
-    <directory>${java.io.tmpdir}</directory>
-    <fields>
-      <field>
-        <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_prefix>srt</sort_prefix>
-    <sort_size>1000000</sort_size>
-    <unique_rows>Y</unique_rows>
-    <attributes/>
-    <GUI>
-      <xloc>672</xloc>
-      <yloc>368</yloc>
+      <xloc>832</xloc>
+      <yloc>448</yloc>
     </GUI>
   </transform>
   <transform_error_handling>
     <error>
-      <source_transform>Insert / update</source_transform>
-      <target_transform>Change job status on error</target_transform>
+      <source_transform>insert_or_update_RDI</source_transform>
+      <target_transform>change_job_status_on_error_RDI</target_transform>
       <is_enabled>Y</is_enabled>
       <nr_valuename/>
       <descriptions_valuename>error_description</descriptions_valuename>
@@ -544,8 +541,8 @@ WHERE
       <min_pct_rows/>
     </error>
     <error>
-      <source_transform>Update</source_transform>
-      <target_transform>Change job status on error</target_transform>
+      <source_transform>update_flags_RDI</source_transform>
+      <target_transform>change_job_status_on_error_RDI</target_transform>
       <is_enabled>Y</is_enabled>
       <nr_valuename/>
       <descriptions_valuename>error_description</descriptions_valuename>
diff --git a/mappings/info_recruits/raw_data/restriction_document_item/recruitment_five_flow_delta.hpl b/mappings/info_recruits/raw_data/restriction_document_item/recruitment_five_flow_delta.hpl
index 249b05c..002c79e 100644
--- a/mappings/info_recruits/raw_data/restriction_document_item/recruitment_five_flow_delta.hpl
+++ b/mappings/info_recruits/raw_data/restriction_document_item/recruitment_five_flow_delta.hpl
@@ -21,33 +21,111 @@
   </notepads>
   <order>
     <hop>
-      <from>Table input</from>
+      <from>Append streams</from>
+      <to>Sort rows</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>failed_restriction_document_item_idm_ids_on_delta</from>
+      <to>Append streams</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>max_update_date_from_restriction_document_item</from>
+      <to>failed_restriction_document_item_idm_ids_on_delta</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>max_update_date_from_restriction_document_item</from>
+      <to>updated_idm_ids_from_source_restriction_document_item</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>updated_idm_ids_from_source_restriction_document_item</from>
+      <to>Append streams</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>Sort rows</from>
       <to>restriction_document_item_flow_delta.hpl</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table input</from>
+      <from>Sort rows</from>
       <to>restriction_document_item_flow_delta.hpl 2</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table input</from>
+      <from>Sort rows</from>
       <to>restriction_document_item_flow_delta.hpl 3</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table input</from>
+      <from>Sort rows</from>
       <to>restriction_document_item_flow_delta.hpl 4</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Table input</from>
+      <from>Sort rows</from>
       <to>restriction_document_item_flow_delta.hpl 5</to>
       <enabled>Y</enabled>
     </hop>
   </order>
   <transform>
-    <name>Table input</name>
+    <name>Append streams</name>
+    <type>Append</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <head_name>updated_idm_ids_from_source_restriction_document_item</head_name>
+    <tail_name>failed_restriction_document_item_idm_ids_on_delta</tail_name>
+    <attributes/>
+    <GUI>
+      <xloc>272</xloc>
+      <yloc>592</yloc>
+    </GUI>
+  </transform>
+  <transform>
+    <name>Sort rows</name>
+    <type>SortRows</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <directory>${java.io.tmpdir}</directory>
+    <prefix>out</prefix>
+    <sort_size>100000</sort_size>
+    <free_memory/>
+    <compress>N</compress>
+    <compress_variable/>
+    <unique_rows>Y</unique_rows>
+    <fields>
+      <field>
+        <name>recruitment_id</name>
+        <ascending>Y</ascending>
+        <case_sensitive>N</case_sensitive>
+        <collator_enabled>N</collator_enabled>
+        <collator_strength>0</collator_strength>
+        <presorted>N</presorted>
+      </field>
+    </fields>
+    <attributes/>
+    <GUI>
+      <xloc>448</xloc>
+      <yloc>592</yloc>
+    </GUI>
+  </transform>
+  <transform>
+    <name>failed_restriction_document_item_idm_ids_on_delta</name>
     <type>TableInput</type>
     <description/>
     <distribute>Y</distribute>
@@ -60,32 +138,42 @@
     <connection>ervu-dashboard</connection>
     <execute_each_row>N</execute_each_row>
     <limit>0</limit>
-    <sql>WITH mud AS (SELECT recruitment_id,
-                    MAX(execution_datetime) AS max_upd_date
-             FROM etl.job_execution
-             WHERE job_name = '${JOB_NAME}'
-               AND status IN ('SUCCESS', 'DELTA_SUCCESS')
-             GROUP BY recruitment_id)
-SELECT r.idm_id
-FROM ervu_dashboard.recruitment r
-         JOIN mud ON mud.recruitment_id = r.idm_id
-         JOIN recruits_info ri
-              ON COALESCE(ri.current_recruitment_id, ri.target_recruitment_id) = r.idm_id
-                  AND ri.updated_at > mud.max_upd_date
-
-union
-
-select r2.idm_id
-from ervu_dashboard.recruitment r2
+    <lookup>max_update_date_from_restriction_document_item</lookup>
+    <sql>select r.idm_id as recruitment_id,
+	? as max_update_date
+from ervu_dashboard.recruitment r
          join etl.job_execution je
-              on r2.idm_id = je.recruitment_id
+              on r.idm_id = je.recruitment_id
 where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
   and je.job_name = '${JOB_NAME}';</sql>
     <variables_active>Y</variables_active>
     <attributes/>
     <GUI>
-      <xloc>352</xloc>
-      <yloc>288</yloc>
+      <xloc>0</xloc>
+      <yloc>784</yloc>
+    </GUI>
+  </transform>
+  <transform>
+    <name>max_update_date_from_restriction_document_item</name>
+    <type>TableInput</type>
+    <description/>
+    <distribute>N</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>ervu-dashboard</connection>
+    <execute_each_row>N</execute_each_row>
+    <limit>0</limit>
+    <sql>select max(updated_at) as max_update_date
+    from ervu_dashboard.restriction_document_item;</sql>
+    <variables_active>N</variables_active>
+    <attributes/>
+    <GUI>
+      <xloc>0</xloc>
+      <yloc>576</yloc>
     </GUI>
   </transform>
   <transform>
@@ -112,6 +200,11 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
         <field>recruitment_id</field>
         <input/>
       </variable_mapping>
+      <variable_mapping>
+        <variable>MAX_UPDATE_DATE</variable>
+        <field>max_update_date</field>
+        <input/>
+      </variable_mapping>
       <inherit_all_vars>Y</inherit_all_vars>
     </parameters>
     <execution_result_target_transform/>
@@ -135,8 +228,8 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <executors_output_transform/>
     <attributes/>
     <GUI>
-      <xloc>656</xloc>
-      <yloc>128</yloc>
+      <xloc>688</xloc>
+      <yloc>432</yloc>
     </GUI>
   </transform>
   <transform>
@@ -163,6 +256,11 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
         <field>recruitment_id</field>
         <input/>
       </variable_mapping>
+      <variable_mapping>
+        <variable>MAX_UPDATE_DATE</variable>
+        <field>max_update_date</field>
+        <input/>
+      </variable_mapping>
       <inherit_all_vars>Y</inherit_all_vars>
     </parameters>
     <execution_result_target_transform/>
@@ -186,8 +284,8 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <executors_output_transform/>
     <attributes/>
     <GUI>
-      <xloc>656</xloc>
-      <yloc>208</yloc>
+      <xloc>688</xloc>
+      <yloc>512</yloc>
     </GUI>
   </transform>
   <transform>
@@ -214,6 +312,11 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
         <field>recruitment_id</field>
         <input/>
       </variable_mapping>
+      <variable_mapping>
+        <variable>MAX_UPDATE_DATE</variable>
+        <field>max_update_date</field>
+        <input/>
+      </variable_mapping>
       <inherit_all_vars>Y</inherit_all_vars>
     </parameters>
     <execution_result_target_transform/>
@@ -237,8 +340,8 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <executors_output_transform/>
     <attributes/>
     <GUI>
-      <xloc>656</xloc>
-      <yloc>288</yloc>
+      <xloc>688</xloc>
+      <yloc>592</yloc>
     </GUI>
   </transform>
   <transform>
@@ -265,6 +368,11 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
         <field>recruitment_id</field>
         <input/>
       </variable_mapping>
+      <variable_mapping>
+        <variable>MAX_UPDATE_DATE</variable>
+        <field>max_update_date</field>
+        <input/>
+      </variable_mapping>
       <inherit_all_vars>Y</inherit_all_vars>
     </parameters>
     <execution_result_target_transform/>
@@ -288,8 +396,8 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <executors_output_transform/>
     <attributes/>
     <GUI>
-      <xloc>656</xloc>
-      <yloc>368</yloc>
+      <xloc>688</xloc>
+      <yloc>672</yloc>
     </GUI>
   </transform>
   <transform>
@@ -316,6 +424,11 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
         <field>recruitment_id</field>
         <input/>
       </variable_mapping>
+      <variable_mapping>
+        <variable>MAX_UPDATE_DATE</variable>
+        <field>max_update_date</field>
+        <input/>
+      </variable_mapping>
       <inherit_all_vars>Y</inherit_all_vars>
     </parameters>
     <execution_result_target_transform/>
@@ -339,8 +452,40 @@ where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')
     <executors_output_transform/>
     <attributes/>
     <GUI>
-      <xloc>656</xloc>
-      <yloc>448</yloc>
+      <xloc>688</xloc>
+      <yloc>752</yloc>
+    </GUI>
+  </transform>
+  <transform>
+    <name>updated_idm_ids_from_source_restriction_document_item</name>
+    <type>TableInput</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>postgres.subpoena</connection>
+    <execute_each_row>N</execute_each_row>
+    <limit>0</limit>
+    <lookup>max_update_date_from_restriction_document_item</lookup>
+    <sql>WITH max_update_date(val) AS (SELECT CAST(? AS timestamp))
+SELECT DISTINCT rd.vk_id as recruitment_id,
+                mud.val as max_update_date
+FROM public.restriction_document_item rdi
+         join public.restriction_document rd on
+    rd.id = coalesce(rdi.restriction_document_create_id,rdi.restriction_document_cancel_id)
+         join public.subpoena s on
+    s.id = rd.subpoena_id
+         JOIN max_update_date mud ON TRUE
+WHERE (mud.val IS NULL OR rdi.updated_at > mud.val);</sql>
+    <variables_active>Y</variables_active>
+    <attributes/>
+    <GUI>
+      <xloc>0</xloc>
+      <yloc>384</yloc>
     </GUI>
   </transform>
   <transform_error_handling>