import purchase order v2

1 files changed, 4 insertions, 2 deletions

diff --git a/import_purchase_order_v2.ktr b/import_purchase_order_v2.ktr
index b8edaf5..dd7c256 100644
--- a/import_purchase_order_v2.ktr
+++ b/import_purchase_order_v2.ktr
@@ -561,7 +561,8 @@
       <schema_name/>
     </partitioning>
     <connection>erp indoteknik production (localhost)</connection>
-    <sql>select * from purchase_order</sql>
+    <sql>select * from purchase_order po
+where po.write_date >= (now() - '3 days'::interval)</sql>
     <limit>0</limit>
     <lookup/>
     <execute_each_row>N</execute_each_row>
@@ -1677,7 +1678,8 @@
       <schema_name/>
     </partitioning>
     <connection>erp indoteknik production (localhost)</connection>
-    <sql>select * from purchase_order_line</sql>
+    <sql>select * from purchase_order_line po
+where po.write_date >= (now() - '3 days'::interval)</sql>
     <limit>0</limit>
     <lookup/>
     <execute_each_row>N</execute_each_row>