You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@couchdb.apache.org by va...@apache.org on 2020/09/09 00:17:48 UTC
[couchdb] branch update-couch-jobs-types-when-setting-any-type
created (now 3c2f0fb)
This is an automated email from the ASF dual-hosted git repository.
vatamane pushed a change to branch update-couch-jobs-types-when-setting-any-type
in repository https://gitbox.apache.org/repos/asf/couchdb.git.
at 3c2f0fb Update all the type monitors after setting any couch jobs type timeout
This branch includes the following new commits:
new 3c2f0fb Update all the type monitors after setting any couch jobs type timeout
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[couchdb] 01/01: Update all the type monitors after setting any
couch jobs type timeout
Posted by va...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
vatamane pushed a commit to branch update-couch-jobs-types-when-setting-any-type
in repository https://gitbox.apache.org/repos/asf/couchdb.git
commit 3c2f0fb04d15d89cdeff1e0ccdb386a322bd6c83
Author: Nick Vatamaniuc <va...@apache.org>
AuthorDate: Tue Sep 8 20:14:18 2020 -0400
Update all the type monitors after setting any couch jobs type timeout
This mostly helps with flaky tests where some jobs might complete before the
type monitor discovers this particular type, so opt to always re-scan and start
notification monitors when any type timeout is set.
---
src/couch_jobs/src/couch_jobs.erl | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/src/couch_jobs/src/couch_jobs.erl b/src/couch_jobs/src/couch_jobs.erl
index f6fb626..f5d6a7b 100644
--- a/src/couch_jobs/src/couch_jobs.erl
+++ b/src/couch_jobs/src/couch_jobs.erl
@@ -293,7 +293,8 @@ wait(Subs, State, Timeout) when is_list(Subs),
set_type_timeout(Type, Timeout) ->
couch_jobs_fdb:tx(couch_jobs_fdb:get_jtx(), fun(JTx) ->
couch_jobs_fdb:set_type_timeout(JTx, Type, Timeout)
- end).
+ end),
+ ok = couch_jobs_server:force_check_types().
-spec clear_type_timeout(job_type()) -> ok.