diff options
Diffstat (limited to 'src/couch_jobs/src/couch_jobs.erl')
| -rw-r--r-- | src/couch_jobs/src/couch_jobs.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/couch_jobs/src/couch_jobs.erl b/src/couch_jobs/src/couch_jobs.erl index f6fb62664..f5d6a7b96 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. |