diff --git a/mappings/info_recruits/citizen_tables/work/work_activity/parallel/work_activity_flow_repeat.hpl b/mappings/info_recruits/citizen_tables/work/work_activity/parallel/work_activity_flow_repeat.hpl
index fd1f699..b7af752 100644
--- a/mappings/info_recruits/citizen_tables/work/work_activity/parallel/work_activity_flow_repeat.hpl
+++ b/mappings/info_recruits/citizen_tables/work/work_activity/parallel/work_activity_flow_repeat.hpl
@@ -9,6 +9,16 @@
     <pipeline_type>Normal</pipeline_type>
     <pipeline_status>0</pipeline_status>
     <parameters>
+      <parameter>
+        <name>IDM_ID</name>
+        <default_value>cc728e0a-af21-49b2-826a-76726aa135e0</default_value>
+        <description/>
+      </parameter>
+      <parameter>
+        <name>JOB_NAME</name>
+        <default_value>work_activity_job</default_value>
+        <description/>
+      </parameter>
     </parameters>
     <capture_transform_performance>N</capture_transform_performance>
     <transform_performance_capturing_delay>1000</transform_performance_capturing_delay>
@@ -91,6 +101,11 @@
       <to>Filter rows</to>
       <enabled>Y</enabled>
     </hop>
+    <hop>
+      <from>Change job status on error</from>
+      <to>Abort</to>
+      <enabled>Y</enabled>
+    </hop>
   </order>
   <transform>
     <name>Block until transforms finish</name>
@@ -152,12 +167,9 @@
         <name>error_description</name>
       </argument>
     </arguments>
-    <connection>ervu-dashboard</connection>
-    <delete_field/>
+    <connection>ervu-dashboard-118</connection>
     <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>
@@ -169,7 +181,6 @@ WHERE job_name = '${JOB_NAME}'
 and recruitment_id = '${IDM_ID}';
 
 </sql>
-    <update_field/>
     <attributes/>
     <GUI>
       <xloc>1776</xloc>
@@ -189,7 +200,7 @@ and recruitment_id = '${IDM_ID}';
     </partitioning>
     <arguments>
 </arguments>
-    <connection>ervu-dashboard</connection>
+    <connection>ervu-dashboard-118</connection>
     <execute_each_row>Y</execute_each_row>
     <quoteString>N</quoteString>
     <replace_variables>Y</replace_variables>
@@ -221,7 +232,7 @@ and recruitment_id = '${IDM_ID}';
     </partitioning>
     <arguments>
 </arguments>
-    <connection>ervu-dashboard</connection>
+    <connection>ervu-dashboard-118</connection>
     <execute_each_row>N</execute_each_row>
     <quoteString>N</quoteString>
     <replace_variables>Y</replace_variables>
@@ -426,7 +437,7 @@ and recruitment_id = '${IDM_ID}';</sql>
       <method>none</method>
       <schema_name/>
     </partitioning>
-    <connection>ervu-dashboard</connection>
+    <connection>ervu-dashboard-118</connection>
     <execute_each_row>N</execute_each_row>
     <sql>WITH filteredData AS (SELECT ri.recruit_id,
                              ri.info -> 'svedFL' -> 'svedTrud' -> 'trudDeyat' as trud_arr
@@ -468,7 +479,7 @@ FROM filteredData fd
       <schema_name/>
     </partitioning>
     <commit>10000</commit>
-    <connection>ervu-dashboard</connection>
+    <connection>ervu-dashboard-118</connection>
     <lookup>
       <key>
         <condition>=</condition>
@@ -537,7 +548,7 @@ FROM filteredData fd
       <schema_name/>
     </partitioning>
     <commit>10000</commit>
-    <connection>ervu-dashboard</connection>
+    <connection>ervu-dashboard-118</connection>
     <lookup>
       <key>
         <condition>=</condition>
@@ -569,6 +580,27 @@ FROM filteredData fd
       <yloc>704</yloc>
     </GUI>
   </transform>
+  <transform>
+    <name>Abort</name>
+    <type>Abort</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <abort_option>ABORT_WITH_ERROR</abort_option>
+    <always_log_rows>Y</always_log_rows>
+    <message/>
+    <row_threshold>0</row_threshold>
+    <attributes/>
+    <GUI>
+      <xloc>1968</xloc>
+      <yloc>704</yloc>
+    </GUI>
+  </transform>
   <transform_error_handling>
     <error>
       <source_transform>citizen_work_activity_upsert</source_transform>