remake again pricelist

10 files changed, 858 insertions, 858 deletions

diff --git a/import_brand.ktr b/import_brand.ktr
index 7b0d313..122b864 100644
--- a/import_brand.ktr
+++ b/import_brand.ktr
@@ -545,69 +545,6 @@
     </hop>
   </order>
   <step>
-    <name>dw Insert / update brand</name>
-    <type>InsertUpdate</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>dw bi indoteknik (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>brand</table>
-      <key>
-        <name>id</name>
-        <field>id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>id</name>
-        <rename>id</rename>
-        <update>N</update>
-      </value>
-      <value>
-        <name>name</name>
-        <rename>x_name</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>type</name>
-        <rename>x_manufacture_level</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>parent</name>
-        <rename>parent</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>pricing_group</name>
-        <rename>pricing_group</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>272</xloc>
-      <yloc>96</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
     <name>Table input</name>
     <type>TableInput</type>
     <description/>
@@ -622,7 +559,7 @@
     <sql>select id, x_name, x_manufacture_level, 
 (select x_name from x_manufactures xm2 where xm2.id = xm.parent_id) as parent, pricing_group
 from x_manufactures xm
-where xm.write_date >= (now() - '15 days'::interval)</sql>
+--where xm.write_date >= (now() - '15 days'::interval)</sql>
     <limit>0</limit>
     <lookup/>
     <execute_each_row>N</execute_each_row>
@@ -760,6 +697,69 @@ where xm.write_date >= (now() - '15 days'::interval)</sql>
       <draw>Y</draw>
     </GUI>
   </step>
+  <step>
+    <name>dw Insert / update brand</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>dw bi indoteknik (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>brand</table>
+      <key>
+        <name>id</name>
+        <field>id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>id</name>
+        <rename>id</rename>
+        <update>N</update>
+      </value>
+      <value>
+        <name>name</name>
+        <rename>x_name</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>type</name>
+        <rename>x_manufacture_level</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>parent</name>
+        <rename>parent</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>pricing_group</name>
+        <rename>pricing_group</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>272</xloc>
+      <yloc>96</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
   <step_error_handling>
   </step_error_handling>
   <slave-step-copy-partition-distribution>
diff --git a/import_product_product.ktr b/import_product_product.ktr
index 8ab3062..c5dbfc6 100644
--- a/import_product_product.ktr
+++ b/import_product_product.ktr
@@ -545,94 +545,6 @@
     </hop>
   </order>
   <step>
-    <name>dw Insert / update product</name>
-    <type>InsertUpdate</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>dw bi indoteknik (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>product</table>
-      <key>
-        <name>product_id</name>
-        <field>product_id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>product_id</name>
-        <rename>product_id</rename>
-        <update>N</update>
-      </value>
-      <value>
-        <name>template_id</name>
-        <rename>template_id</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>name</name>
-        <rename>name</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>active</name>
-        <rename>active</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>brand_id</name>
-        <rename>brand_id</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>item_code</name>
-        <rename>item_code</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>parent_category</name>
-        <rename>parent_category</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>image</name>
-        <rename>image</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>description</name>
-        <rename>description</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>weight</name>
-        <rename>weight</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>448</xloc>
-      <yloc>128</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
     <name>Table input</name>
     <type>TableInput</type>
     <description/>
@@ -654,7 +566,7 @@ pt.website_description as description,
 pt.weight
 from product_product pp
 join product_template pt on pt.id = pp.product_tmpl_id
-where pp.write_date >= (now() - '5 days'::interval)</sql>
+--where pp.write_date >= (now() - '5 days'::interval)</sql>
     <limit>0</limit>
     <lookup/>
     <execute_each_row>N</execute_each_row>
@@ -907,6 +819,94 @@ where pp.write_date >= (now() - '5 days'::interval)</sql>
       <draw>Y</draw>
     </GUI>
   </step>
+  <step>
+    <name>dw Insert / update product</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>dw bi indoteknik (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>product</table>
+      <key>
+        <name>product_id</name>
+        <field>product_id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>product_id</name>
+        <rename>product_id</rename>
+        <update>N</update>
+      </value>
+      <value>
+        <name>template_id</name>
+        <rename>template_id</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>name</name>
+        <rename>name</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>active</name>
+        <rename>active</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>brand_id</name>
+        <rename>brand_id</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>item_code</name>
+        <rename>item_code</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>parent_category</name>
+        <rename>parent_category</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>image</name>
+        <rename>image</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>description</name>
+        <rename>description</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>weight</name>
+        <rename>weight</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>448</xloc>
+      <yloc>128</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
   <step_error_handling>
   </step_error_handling>
   <slave-step-copy-partition-distribution>
diff --git a/import_purchase_order.ktr b/import_purchase_order.ktr
index f297a94..e548fbd 100644
--- a/import_purchase_order.ktr
+++ b/import_purchase_order.ktr
@@ -545,119 +545,6 @@
     </hop>
   </order>
   <step>
-    <name>dw Insert / update po</name>
-    <type>InsertUpdate</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>dw bi indoteknik (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>purchase_order_dw</table>
-      <key>
-        <name>line_id</name>
-        <field>line_id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>po_date</name>
-        <rename>po_date</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>line_date</name>
-        <rename>line_date</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>documentno</name>
-        <rename>documentno</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>state</name>
-        <rename>state</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>partner_id</name>
-        <rename>partner_id</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>vendor</name>
-        <rename>vendor</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>product_id</name>
-        <rename>product_id</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>qty</name>
-        <rename>qty</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>price_unit</name>
-        <rename>price_unit</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>price_subtotal</name>
-        <rename>price_subtotal</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>line_id</name>
-        <rename>line_id</rename>
-        <update>N</update>
-      </value>
-      <value>
-        <name>year_month</name>
-        <rename>year_month</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>year_date</name>
-        <rename>year_date</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>month_date</name>
-        <rename>month_date</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>day_date</name>
-        <rename>day_date</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>432</xloc>
-      <yloc>96</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
     <name>Table input</name>
     <type>TableInput</type>
     <description/>
@@ -680,7 +567,7 @@ get_quarter(to_char(pol.write_date::timestamp with time zone, 'MM'::text))
 from purchase_order po
 join res_partner rp on rp.id = po.partner_id
 join purchase_order_line pol on pol.order_id = po.id
-where pol.write_date >= (now() - '5 days'::interval)</sql>
+--where pol.write_date >= (now() - '5 days'::interval)</sql>
     <limit>0</limit>
     <lookup/>
     <execute_each_row>N</execute_each_row>
@@ -1071,6 +958,119 @@ where pol.write_date >= (now() - '5 days'::interval)</sql>
       <draw>Y</draw>
     </GUI>
   </step>
+  <step>
+    <name>dw Insert / update po</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>dw bi indoteknik (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>purchase_order_dw</table>
+      <key>
+        <name>line_id</name>
+        <field>line_id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>po_date</name>
+        <rename>po_date</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>line_date</name>
+        <rename>line_date</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>documentno</name>
+        <rename>documentno</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>state</name>
+        <rename>state</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>partner_id</name>
+        <rename>partner_id</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>vendor</name>
+        <rename>vendor</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>product_id</name>
+        <rename>product_id</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>qty</name>
+        <rename>qty</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>price_unit</name>
+        <rename>price_unit</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>price_subtotal</name>
+        <rename>price_subtotal</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>line_id</name>
+        <rename>line_id</rename>
+        <update>N</update>
+      </value>
+      <value>
+        <name>year_month</name>
+        <rename>year_month</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>year_date</name>
+        <rename>year_date</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>month_date</name>
+        <rename>month_date</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>day_date</name>
+        <rename>day_date</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>432</xloc>
+      <yloc>96</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
   <step_error_handling>
   </step_error_handling>
   <slave-step-copy-partition-distribution>
diff --git a/import_purchase_pricelist.ktr b/import_purchase_pricelist.ktr
index 384d7ff..2ab9f29 100644
--- a/import_purchase_pricelist.ktr
+++ b/import_purchase_pricelist.ktr
@@ -545,89 +545,6 @@
     </hop>
   </order>
   <step>
-    <name>dw Insert / update purchase pl</name>
-    <type>InsertUpdate</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>dw bi indoteknik (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>purchase_pricelist_dw</table>
-      <key>
-        <name>id</name>
-        <field>id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>id</name>
-        <rename>id</rename>
-        <update>N</update>
-      </value>
-      <value>
-        <name>product_id</name>
-        <rename>product_id</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>vendor_id</name>
-        <rename>vendor_id</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>vendor</name>
-        <rename>vendor</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>product_price</name>
-        <rename>product_price</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>write_date</name>
-        <rename>write_date</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>system_price</name>
-        <rename>system_price</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>system_last_update</name>
-        <rename>system_last_update</rename>
-        <update>Y</update>
-      </value>
-      <value>
-        <name>human_last_update</name>
-        <rename>human_last_update</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>512</xloc>
-      <yloc>336</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
     <name>Table input</name>
     <type>TableInput</type>
     <description/>
@@ -643,7 +560,7 @@
 pp.system_price, pp.system_last_update, pp.human_last_update
 from purchase_pricelist pp
 join res_partner rp on rp.id = pp.vendor_id
-where pp.write_date >= (now() - '10 days'::interval)</sql>
+--where pp.write_date >= (now() - '10 days'::interval)</sql>
     <limit>0</limit>
     <lookup/>
     <execute_each_row>N</execute_each_row>
@@ -873,6 +790,89 @@ where pp.write_date >= (now() - '10 days'::interval)</sql>
       <draw>Y</draw>
     </GUI>
   </step>
+  <step>
+    <name>dw Insert / update purchase pl</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>dw bi indoteknik (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>purchase_pricelist_dw</table>
+      <key>
+        <name>id</name>
+        <field>id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>id</name>
+        <rename>id</rename>
+        <update>N</update>
+      </value>
+      <value>
+        <name>product_id</name>
+        <rename>product_id</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>vendor_id</name>
+        <rename>vendor_id</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>vendor</name>
+        <rename>vendor</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>product_price</name>
+        <rename>product_price</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>write_date</name>
+        <rename>write_date</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>system_price</name>
+        <rename>system_price</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>system_last_update</name>
+        <rename>system_last_update</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>human_last_update</name>
+        <rename>human_last_update</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>512</xloc>
+      <yloc>336</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
   <step_error_handling>
   </step_error_handling>
   <slave-step-copy-partition-distribution>
diff --git a/insert_update_pricelist.ktr b/insert_update_pricelist.ktr
index 330a5d0..482819a 100644
--- a/insert_update_pricelist.ktr
+++ b/insert_update_pricelist.ktr
@@ -572,12 +572,12 @@
     <hop>
       <from>p Insert / update base pl</from>
       <to>base solr flag pt</to>
-      <enabled>Y</enabled>
+      <enabled>N</enabled>
     </hop>
     <hop>
       <from>base solr flag pt</from>
       <to>base solr flag pp</to>
-      <enabled>Y</enabled>
+      <enabled>N</enabled>
     </hop>
   </order>
   <step>
@@ -787,8 +787,8 @@
     </GUI>
   </step>
   <step>
-    <name>base solr flag pt</name>
-    <type>InsertUpdate</type>
+    <name>Merge join</name>
+    <type>MergeJoin</type>
     <description/>
     <distribute>Y</distribute>
     <custom_distribution/>
@@ -797,24 +797,15 @@
       <method>none</method>
       <schema_name/>
     </partitioning>
-    <connection>erp indoteknik production (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>product_template</table>
-      <key>
-        <name>template_id</name>
-        <field>id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>solr_flag</name>
-        <rename>solr_flag</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
+    <join_type>LEFT OUTER</join_type>
+    <step1>price compute</step1>
+    <step2>price erp</step2>
+    <keys_1>
+      <key>product_id</key>
+    </keys_1>
+    <keys_2>
+      <key>product_id</key>
+    </keys_2>
     <attributes/>
     <cluster_schema/>
     <remotesteps>
@@ -824,12 +815,44 @@
       </output>
     </remotesteps>
     <GUI>
-      <xloc>912</xloc>
+      <xloc>320</xloc>
       <yloc>272</yloc>
       <draw>Y</draw>
     </GUI>
   </step>
   <step>
+    <name>Write to log</name>
+    <type>WriteToLog</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <loglevel>log_level_nothing</loglevel>
+    <displayHeader>Y</displayHeader>
+    <limitRows>N</limitRows>
+    <limitRowsNumber>0</limitRowsNumber>
+    <logmessage/>
+    <fields>
+      </fields>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>464</xloc>
+      <yloc>400</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
     <name>base solr flag pp</name>
     <type>InsertUpdate</type>
     <description/>
@@ -873,8 +896,8 @@
     </GUI>
   </step>
   <step>
-    <name>Merge join</name>
-    <type>MergeJoin</type>
+    <name>base solr flag pt</name>
+    <type>InsertUpdate</type>
     <description/>
     <distribute>Y</distribute>
     <custom_distribution/>
@@ -883,15 +906,24 @@
       <method>none</method>
       <schema_name/>
     </partitioning>
-    <join_type>LEFT OUTER</join_type>
-    <step1>price compute</step1>
-    <step2>price erp</step2>
-    <keys_1>
-      <key>product_id</key>
-    </keys_1>
-    <keys_2>
-      <key>product_id</key>
-    </keys_2>
+    <connection>erp indoteknik production (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>product_template</table>
+      <key>
+        <name>template_id</name>
+        <field>id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>solr_flag</name>
+        <rename>solr_flag</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
     <attributes/>
     <cluster_schema/>
     <remotesteps>
@@ -901,44 +933,12 @@
       </output>
     </remotesteps>
     <GUI>
-      <xloc>320</xloc>
+      <xloc>912</xloc>
       <yloc>272</yloc>
       <draw>Y</draw>
     </GUI>
   </step>
   <step>
-    <name>Write to log</name>
-    <type>WriteToLog</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <loglevel>log_level_nothing</loglevel>
-    <displayHeader>Y</displayHeader>
-    <limitRows>N</limitRows>
-    <limitRowsNumber>0</limitRowsNumber>
-    <logmessage/>
-    <fields>
-      </fields>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>464</xloc>
-      <yloc>400</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
     <name>p Insert / update base pl</name>
     <type>InsertUpdate</type>
     <description/>
diff --git a/insert_update_pricelist1.ktr b/insert_update_pricelist1.ktr
index d7ab991..660fa8e 100644
--- a/insert_update_pricelist1.ktr
+++ b/insert_update_pricelist1.ktr
@@ -572,12 +572,12 @@
     <hop>
       <from>p Insert / update tier1</from>
       <to>pl1 solr flag pt</to>
-      <enabled>Y</enabled>
+      <enabled>N</enabled>
     </hop>
     <hop>
       <from>pl1 solr flag pt</from>
       <to>pl1 solr flag pp</to>
-      <enabled>Y</enabled>
+      <enabled>N</enabled>
     </hop>
   </order>
   <step>
@@ -799,92 +799,6 @@
     </GUI>
   </step>
   <step>
-    <name>pl1 solr flag pt</name>
-    <type>InsertUpdate</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>erp indoteknik production (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>product_template</table>
-      <key>
-        <name>template_id</name>
-        <field>id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>solr_flag</name>
-        <rename>solr_flag</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>928</xloc>
-      <yloc>272</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
-    <name>pl1 solr flag pp</name>
-    <type>InsertUpdate</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>erp indoteknik production (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>product_product</table>
-      <key>
-        <name>product_id</name>
-        <field>id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>solr_flag</name>
-        <rename>solr_flag</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>1120</xloc>
-      <yloc>272</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
     <name>Merge join</name>
     <type>MergeJoin</type>
     <description/>
@@ -1060,6 +974,92 @@
     </GUI>
   </step>
   <step>
+    <name>pl1 solr flag pp</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>erp indoteknik production (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>product_product</table>
+      <key>
+        <name>product_id</name>
+        <field>id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>solr_flag</name>
+        <rename>solr_flag</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>1120</xloc>
+      <yloc>272</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
+    <name>pl1 solr flag pt</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>erp indoteknik production (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>product_template</table>
+      <key>
+        <name>template_id</name>
+        <field>id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>solr_flag</name>
+        <rename>solr_flag</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>928</xloc>
+      <yloc>272</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
     <name>price compute</name>
     <type>TableInput</type>
     <description/>
diff --git a/insert_update_pricelist2.ktr b/insert_update_pricelist2.ktr
index 10bf73c..461b15c 100644
--- a/insert_update_pricelist2.ktr
+++ b/insert_update_pricelist2.ktr
@@ -572,12 +572,12 @@
     <hop>
       <from>p Insert / update tier2</from>
       <to>pl2 solr flag pt</to>
-      <enabled>Y</enabled>
+      <enabled>N</enabled>
     </hop>
     <hop>
       <from>pl2 solr flag pt</from>
       <to>pl2 solr flag pp</to>
-      <enabled>Y</enabled>
+      <enabled>N</enabled>
     </hop>
   </order>
   <step>
@@ -799,92 +799,6 @@
     </GUI>
   </step>
   <step>
-    <name>pl2 solr flag pt</name>
-    <type>InsertUpdate</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>erp indoteknik production (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>product_template</table>
-      <key>
-        <name>template_id</name>
-        <field>id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>solr_flag</name>
-        <rename>solr_flag</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>912</xloc>
-      <yloc>272</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
-    <name>pl2 solr flag pp</name>
-    <type>InsertUpdate</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>erp indoteknik production (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>product_product</table>
-      <key>
-        <name>product_id</name>
-        <field>id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>solr_flag</name>
-        <rename>solr_flag</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>1088</xloc>
-      <yloc>272</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
     <name>Merge join</name>
     <type>MergeJoin</type>
     <description/>
@@ -1060,6 +974,92 @@
     </GUI>
   </step>
   <step>
+    <name>pl2 solr flag pp</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>erp indoteknik production (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>product_product</table>
+      <key>
+        <name>product_id</name>
+        <field>id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>solr_flag</name>
+        <rename>solr_flag</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>1088</xloc>
+      <yloc>272</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
+    <name>pl2 solr flag pt</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>erp indoteknik production (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>product_template</table>
+      <key>
+        <name>template_id</name>
+        <field>id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>solr_flag</name>
+        <rename>solr_flag</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>912</xloc>
+      <yloc>272</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
     <name>price compute</name>
     <type>TableInput</type>
     <description/>
diff --git a/insert_update_pricelist3.ktr b/insert_update_pricelist3.ktr
index ec3e954..e1cc183 100644
--- a/insert_update_pricelist3.ktr
+++ b/insert_update_pricelist3.ktr
@@ -572,12 +572,12 @@
     <hop>
       <from>p Insert / update tier3</from>
       <to>pl3 solr flag pt</to>
-      <enabled>Y</enabled>
+      <enabled>N</enabled>
     </hop>
     <hop>
       <from>pl3 solr flag pt</from>
       <to>pl3 solr flag pp</to>
-      <enabled>Y</enabled>
+      <enabled>N</enabled>
     </hop>
   </order>
   <step>
@@ -799,92 +799,6 @@
     </GUI>
   </step>
   <step>
-    <name>pl3 solr flag pt</name>
-    <type>InsertUpdate</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>erp indoteknik production (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>product_template</table>
-      <key>
-        <name>template_id</name>
-        <field>id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>solr_flag</name>
-        <rename>solr_flag</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>912</xloc>
-      <yloc>272</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
-    <name>pl3 solr flag pp</name>
-    <type>InsertUpdate</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>erp indoteknik production (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>product_product</table>
-      <key>
-        <name>product_id</name>
-        <field>id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>solr_flag</name>
-        <rename>solr_flag</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>1088</xloc>
-      <yloc>272</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
     <name>Merge join</name>
     <type>MergeJoin</type>
     <description/>
@@ -1060,6 +974,92 @@
     </GUI>
   </step>
   <step>
+    <name>pl3 solr flag pp</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>erp indoteknik production (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>product_product</table>
+      <key>
+        <name>product_id</name>
+        <field>id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>solr_flag</name>
+        <rename>solr_flag</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>1088</xloc>
+      <yloc>272</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
+    <name>pl3 solr flag pt</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>erp indoteknik production (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>product_template</table>
+      <key>
+        <name>template_id</name>
+        <field>id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>solr_flag</name>
+        <rename>solr_flag</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>912</xloc>
+      <yloc>272</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
     <name>price compute</name>
     <type>TableInput</type>
     <description/>
diff --git a/insert_update_pricelist4.ktr b/insert_update_pricelist4.ktr
index f8d75e6..79f9d0e 100644
--- a/insert_update_pricelist4.ktr
+++ b/insert_update_pricelist4.ktr
@@ -572,12 +572,12 @@
     <hop>
       <from>p Insert / update tier4</from>
       <to>pl4 solr flag pt</to>
-      <enabled>Y</enabled>
+      <enabled>N</enabled>
     </hop>
     <hop>
       <from>pl4 solr flag pt</from>
       <to>pl4 solr flag pp</to>
-      <enabled>Y</enabled>
+      <enabled>N</enabled>
     </hop>
   </order>
   <step>
@@ -799,92 +799,6 @@
     </GUI>
   </step>
   <step>
-    <name>pl4 solr flag pt</name>
-    <type>InsertUpdate</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>erp indoteknik production (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>product_template</table>
-      <key>
-        <name>template_id</name>
-        <field>id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>solr_flag</name>
-        <rename>solr_flag</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>912</xloc>
-      <yloc>272</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
-    <name>pl4 solr flag pp</name>
-    <type>InsertUpdate</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>erp indoteknik production (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>product_product</table>
-      <key>
-        <name>product_id</name>
-        <field>id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>solr_flag</name>
-        <rename>solr_flag</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>1088</xloc>
-      <yloc>272</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
     <name>Merge join</name>
     <type>MergeJoin</type>
     <description/>
@@ -1060,6 +974,92 @@
     </GUI>
   </step>
   <step>
+    <name>pl4 solr flag pp</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>erp indoteknik production (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>product_product</table>
+      <key>
+        <name>product_id</name>
+        <field>id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>solr_flag</name>
+        <rename>solr_flag</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>1088</xloc>
+      <yloc>272</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
+    <name>pl4 solr flag pt</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>erp indoteknik production (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>product_template</table>
+      <key>
+        <name>template_id</name>
+        <field>id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>solr_flag</name>
+        <rename>solr_flag</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>912</xloc>
+      <yloc>272</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
     <name>price compute</name>
     <type>TableInput</type>
     <description/>
diff --git a/insert_update_pricelist5.ktr b/insert_update_pricelist5.ktr
index d06bd59..ae14135 100644
--- a/insert_update_pricelist5.ktr
+++ b/insert_update_pricelist5.ktr
@@ -572,12 +572,12 @@
     <hop>
       <from>p Insert / update tier5</from>
       <to>pl5 solr flag pt</to>
-      <enabled>Y</enabled>
+      <enabled>N</enabled>
     </hop>
     <hop>
       <from>pl5 solr flag pt</from>
       <to>pl5 solr flag pp</to>
-      <enabled>Y</enabled>
+      <enabled>N</enabled>
     </hop>
   </order>
   <step>
@@ -799,92 +799,6 @@
     </GUI>
   </step>
   <step>
-    <name>pl5 solr flag pt</name>
-    <type>InsertUpdate</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>erp indoteknik production (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>product_template</table>
-      <key>
-        <name>template_id</name>
-        <field>id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>solr_flag</name>
-        <rename>solr_flag</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>912</xloc>
-      <yloc>272</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
-    <name>pl5 solr flag pp</name>
-    <type>InsertUpdate</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <connection>erp indoteknik production (localhost)</connection>
-    <commit>100</commit>
-    <update_bypassed>N</update_bypassed>
-    <lookup>
-      <schema>public</schema>
-      <table>product_product</table>
-      <key>
-        <name>product_id</name>
-        <field>id</field>
-        <condition>=</condition>
-        <name2/>
-      </key>
-      <value>
-        <name>solr_flag</name>
-        <rename>solr_flag</rename>
-        <update>Y</update>
-      </value>
-    </lookup>
-    <attributes/>
-    <cluster_schema/>
-    <remotesteps>
-      <input>
-      </input>
-      <output>
-      </output>
-    </remotesteps>
-    <GUI>
-      <xloc>1088</xloc>
-      <yloc>272</yloc>
-      <draw>Y</draw>
-    </GUI>
-  </step>
-  <step>
     <name>Merge join</name>
     <type>MergeJoin</type>
     <description/>
@@ -1060,6 +974,92 @@
     </GUI>
   </step>
   <step>
+    <name>pl5 solr flag pp</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>erp indoteknik production (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>product_product</table>
+      <key>
+        <name>product_id</name>
+        <field>id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>solr_flag</name>
+        <rename>solr_flag</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>1088</xloc>
+      <yloc>272</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
+    <name>pl5 solr flag pt</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>erp indoteknik production (localhost)</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema>public</schema>
+      <table>product_template</table>
+      <key>
+        <name>template_id</name>
+        <field>id</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>solr_flag</name>
+        <rename>solr_flag</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>912</xloc>
+      <yloc>272</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
     <name>price compute</name>
     <type>TableInput</type>
     <description/>