This is an automated email from the ASF dual-hosted git repository.
japetrsn pushed a commit to branch master
in repository
https://gitbox.apache.org/repos/asf/incubator-openwhisk-package-kafka.git
The following commit(s) were added to refs/heads/master by this push:
new e242c13 Do Not Disable Triggers on Document Update Conflicts (#307)
e242c13 is described below
commit e242c13d05a11c4d2df5968e13ba1e0f3ef95c72
Author: James Dubee <[email protected]>
AuthorDate: Tue Nov 13 14:07:33 2018 -0500
Do Not Disable Triggers on Document Update Conflicts (#307)
---
provider/consumer.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/provider/consumer.py b/provider/consumer.py
index 12cfd75..865c209 100644
--- a/provider/consumer.py
+++ b/provider/consumer.py
@@ -359,9 +359,9 @@ class ConsumerProcess (Process):
# decide whether or not to disable a trigger based on the status code
returned
# from firing the trigger. Specifically, disable on all 4xx status codes
- # except 408 (gateway timeout) and 429 (throttle)
+ # except 408 (gateway timeout), 409 (document update conflict), and 429
(throttle)
def __shouldDisable(self, status_code):
- return status_code in range(400, 500) and status_code not in [408, 429]
+ return status_code in range(400, 500) and status_code not in [408,
409, 429]
def __fireTrigger(self, messages):
if self.__shouldRun():
