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:49 UTC

[couchdb] 01/01: Update all the type monitors after setting any couch jobs type timeout

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.