Adjusts pull.simple components to act like polling components

But we cannot convert them because we can floats for the interval and the polling component does not support that. So we try to mimic the beehaviour. * Allows floats for parse_duration_literal * Adds interval argument for components * Adds duration literal parsing of interval/wait argument
HazardDede · Nov 12, 2019 · 0630204 · 0630204
1 parent 76200d3
commit 0630204
Show file tree

Hide file tree

Showing 63 changed files with 223 additions and 128 deletions.
diff --git a/README.md b/README.md
@@ -65,7 +65,7 @@ It is up to you. I prefer yaml...
   pull:
     plugin: pnp.plugins.pull.simple.Repeat
     args:
-      wait: 1
+      interval: 1s
       repeat: "Hello World"
   push:
     - plugin: pnp.plugins.push.simple.Echo
@@ -245,7 +245,7 @@ Given the example ...
   pull:
     plugin: pnp.plugins.pull.simple.Count
     args:
-      wait: 1
+      interval: 1s
   push:
     plugin: pnp.plugins.push.fs.FileDump
     selector:
@@ -309,7 +309,7 @@ you can perform for each loops for pushes.
   pull:
     plugin: pnp.plugins.pull.simple.Repeat
     args:
-      wait: 1
+      interval: 1s
       repeat:
         - 1
         - 2
@@ -329,7 +329,7 @@ If you need the selector to augment your list, use a `push.simple.Nop` with `unw
   pull:
     plugin: pnp.plugins.pull.simple.Repeat
     args:
-      wait: 1
+      interval: 1s
       repeat:
         - 1
         - 2
@@ -534,7 +534,7 @@ Additional example:
   pull:
     plugin: pnp.plugins.pull.simple.Repeat
     args:
-      wait: 1
+      interval: 1s
       repeat: "Hello World"
   push:
     - plugin: pnp.plugins.push.simple.Echo
@@ -581,7 +581,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Repeat
       args:
-        wait: 1
+        interval: 1s
         repeat: "Hello World"
     push:
       - plugin: pnp.plugins.push.simple.Echo

diff --git a/config/01_hello_world.yaml b/config/01_hello_world.yaml
@@ -8,7 +8,7 @@
   pull:
     plugin: pnp.plugins.pull.simple.Repeat
     args:
-      wait: 1
+      interval: 1s
       repeat: "Hello World"
   push:
     - plugin: pnp.plugins.push.simple.Echo
diff --git a/config/02_multipush.yaml b/config/02_multipush.yaml
@@ -6,7 +6,7 @@
   pull:
     plugin: pnp.plugins.pull.simple.Repeat
     args:
-      wait: 1
+      interval: 1s
       repeat: "Hello World"
   push:
     - plugin: pnp.plugins.push.simple.Echo

diff --git a/config/03_lambda_selector.yaml b/config/03_lambda_selector.yaml
@@ -3,7 +3,7 @@
   pull:
     plugin: pnp.plugins.pull.simple.Repeat
     args:
-      wait: 1
+      interval: 1s
       repeat: "Hello World"
   push:
     - plugin: pnp.plugins.push.simple.Echo

diff --git a/config/03_selector.yaml b/config/03_selector.yaml
@@ -9,7 +9,7 @@
   pull:
     plugin: pnp.plugins.pull.simple.Repeat
     args:
-      wait: 1
+      interval: 1s
       repeat: "Hello World"
   push:
     - plugin: pnp.plugins.push.simple.Echo

diff --git a/config/04_suppress.yaml b/config/04_suppress.yaml
@@ -8,7 +8,7 @@
   pull:
     plugin: pnp.plugins.pull.simple.Count
     args:
-      wait: 1
+      interval: 1s
   push:
     - plugin: pnp.plugins.push.simple.Echo
       # variable suppress is basically a constant that tells the push not to execute

diff --git a/config/05_dependencies.yaml b/config/05_dependencies.yaml
@@ -11,7 +11,7 @@
   pull:
     plugin: pnp.plugins.pull.simple.Repeat
     args:
-      wait: 1
+      interval: 1s
       repeat: "Hello World"
   push:
     - plugin: pnp.plugins.push.simple.Nop

diff --git a/config/06_complex.yaml b/config/06_complex.yaml
@@ -9,7 +9,7 @@
   pull:
     plugin: pnp.plugins.pull.simple.Repeat
     args:
-      wait: 1
+      interval: 1s
       repeat: "Hello World"
   push:
     - plugin: pnp.plugins.push.simple.Nop

diff --git a/config/07_reference.yaml b/config/07_reference.yaml
@@ -10,7 +10,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Repeat
       args:
-        wait: 1
+        interval: 1s
         repeat: "Hello World"
     push:
       - <<: *echo_plugin

diff --git a/config/08_envelope.yaml b/config/08_envelope.yaml
@@ -3,7 +3,7 @@
   pull:
     plugin: pnp.plugins.pull.simple.Count
     args:
-      wait: 1
+      interval: 1s
   push:
     plugin: pnp.plugins.push.fs.FileDump
     selector:

diff --git a/config/engines/process.yaml b/config/engines/process.yaml
@@ -8,7 +8,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Repeat
       args:
-        wait: 1
+        interval: 1s
         repeat: "Hello World"
     push:
       - plugin: pnp.plugins.push.simple.Echo
diff --git a/config/engines/sequential.yaml b/config/engines/sequential.yaml
@@ -7,7 +7,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Count
       args:
-        wait: 1
+        interval: 1s
         from_cnt: 1
         to_cnt: 4
     push:

diff --git a/config/engines/threading.yaml b/config/engines/threading.yaml
@@ -8,7 +8,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Repeat
       args:
-        wait: 1
+        interval: 1s
         repeat: "Hello World"
     push:
       - plugin: pnp.plugins.push.simple.Echo
diff --git a/config/readme/01_hello_world.yaml b/config/readme/01_hello_world.yaml
@@ -2,7 +2,7 @@
   pull:
     plugin: pnp.plugins.pull.simple.Repeat
     args:
-      wait: 1
+      interval: 1s
       repeat: "Hello World"
   push:
     - plugin: pnp.plugins.push.simple.Echo
diff --git a/config/readme/05_envelope.yaml b/config/readme/05_envelope.yaml
@@ -2,7 +2,7 @@
   pull:
     plugin: pnp.plugins.pull.simple.Count
     args:
-      wait: 1
+      interval: 1s
   push:
     plugin: pnp.plugins.push.fs.FileDump
     selector:

diff --git a/config/readme/06_unwrapping.yaml b/config/readme/06_unwrapping.yaml
@@ -2,7 +2,7 @@
   pull:
     plugin: pnp.plugins.pull.simple.Repeat
     args:
-      wait: 1
+      interval: 1s
       repeat:
         - 1
         - 2

diff --git a/config/readme/07_unwrapping_nop.yaml b/config/readme/07_unwrapping_nop.yaml
@@ -2,7 +2,7 @@
   pull:
     plugin: pnp.plugins.pull.simple.Repeat
     args:
-      wait: 1
+      interval: 1s
       repeat:
         - 1
         - 2

diff --git a/config/readme/08_udf.yaml b/config/readme/08_udf.yaml
@@ -17,7 +17,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Repeat
       args:
-        wait: 1
+        interval: 1s
         repeat: "Hello World"
     push:
       - plugin: pnp.plugins.push.simple.Echo

diff --git a/config/readme/09_udf_throttle.yaml b/config/readme/09_udf_throttle.yaml
@@ -11,7 +11,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Repeat
       args:
-        wait: 1
+        interval: 1s
         repeat: "Hello World"
     push:
       - plugin: pnp.plugins.push.simple.Echo

diff --git a/docs/engines/README.md b/docs/engines/README.md
@@ -37,7 +37,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Count
       args:
-        wait: 1
+        interval: 1s
         from_cnt: 1
         to_cnt: 4
     push:
@@ -62,7 +62,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Repeat
       args:
-        wait: 1
+        interval: 1s
         repeat: "Hello World"
     push:
       - plugin: pnp.plugins.push.simple.Echo
@@ -86,7 +86,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Repeat
       args:
-        wait: 1
+        interval: 1s
         repeat: "Hello World"
     push:
       - plugin: pnp.plugins.push.simple.Echo
@@ -109,7 +109,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Repeat
       args:
-        wait: 1
+        interval: 1s
         repeat: "Hello World"
     push:
       - plugin: pnp.plugins.push.simple.Echo

diff --git a/docs/engines/async.yaml b/docs/engines/async.yaml
@@ -9,7 +9,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Repeat
       args:
-        wait: 1
+        interval: 1s
         repeat: "Hello World"
     push:
       - plugin: pnp.plugins.push.simple.Echo
diff --git a/docs/engines/process.yaml b/docs/engines/process.yaml
@@ -10,7 +10,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Repeat
       args:
-        wait: 1
+        interval: 1s
         repeat: "Hello World"
     push:
       - plugin: pnp.plugins.push.simple.Echo
diff --git a/docs/engines/sequential.yaml b/docs/engines/sequential.yaml
@@ -10,7 +10,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Count
       args:
-        wait: 1
+        interval: 1s
         from_cnt: 1
         to_cnt: 4
     push:

diff --git a/docs/engines/threading.yaml b/docs/engines/threading.yaml
@@ -10,7 +10,7 @@ tasks:
     pull:
       plugin: pnp.plugins.pull.simple.Repeat
       args:
-        wait: 1
+        interval: 1s
         repeat: "Hello World"
     push:
       - plugin: pnp.plugins.push.simple.Echo