Guard against early notifier.

metaskills · metaskills · commit ccbe358a8d6c · 2021-07-01T12:24:16.000-04:00
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,7 @@
+## [0.0.8] - 2021-06-28
+
+- Guard against early notifier.
+
 ## [0.0.7] - 2021-06-28
 
 - Fix queue logger.
diff --git a/Gemfile.lock b/Gemfile.lock
@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    lambda_punch (0.0.7)
+    lambda_punch (0.0.8)
       concurrent-ruby
       rake
       rb-inotify
diff --git a/lib/lambda_punch/version.rb b/lib/lambda_punch/version.rb
@@ -1,3 +1,3 @@
 module LambdaPunch
-  VERSION = "0.0.7"
+  VERSION = "0.0.8"
 end
diff --git a/lib/lambda_punch/worker.rb b/lib/lambda_punch/worker.rb
@@ -64,7 +64,7 @@ def initialize(event_payload)
     # also ensures any clean up is done. For example, closing file notifications.
     #
     def call
-      Timeout.timeout(timeout) { @notifier.process }
+      Timeout.timeout(timeout) { @notifier.process unless invoked? }
     rescue Timeout::Error
       logger.error "Worker#call => Function timeout reached."
     ensure

Original file line number	Diff line number	Diff line change
`@@ -64,7 +64,7 @@ def initialize(event_payload)`
`64`	`64`	`# also ensures any clean up is done. For example, closing file notifications.`
`65`	`65`	`#`
`66`	`66`	`def call`
`67`		`- Timeout.timeout(timeout) { @notifier.process }`
	`67`	`+ Timeout.timeout(timeout) { @notifier.process unless invoked? }`
`68`	`68`	`rescue Timeout::Error`
`69`	`69`	`logger.error "Worker#call => Function timeout reached."`
`70`	`70`	`ensure`