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.