diff options
| author | Tony Sun <tony.sun427@gmail.com> | 2020-08-25 13:07:26 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-08-25 13:07:26 -0700 |
| commit | 926be1b1aad9c82318d28646d176968010247e5a (patch) | |
| tree | 47109011ef4418ac27af872f1436e52ed0b806e3 | |
| parent | 790dafffba0af12e1c87dab6159d0864f55b16f1 (diff) | |
| parent | 978f7dae6748e09830593f132e6977682e7d9453 (diff) | |
| download | couchdb-926be1b1aad9c82318d28646d176968010247e5a.tar.gz | |
Merge pull request #3101 from apache/fix-couch-jobs-for-active-tasks
clear jobs data in active area during removal
| -rw-r--r-- | src/couch_jobs/src/couch_jobs_fdb.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/couch_jobs/src/couch_jobs_fdb.erl b/src/couch_jobs/src/couch_jobs_fdb.erl index 891aedc79..3fcad554a 100644 --- a/src/couch_jobs/src/couch_jobs_fdb.erl +++ b/src/couch_jobs/src/couch_jobs_fdb.erl @@ -119,8 +119,9 @@ remove(#{jtx := true} = JTx0, #{job := true} = Job) -> #{type := Type, id := JobId} = Job, Key = job_key(JTx, Job), case get_job_val(Tx, Key) of - #jv{stime = STime} -> + #jv{stime = STime, seq = Seq} -> couch_jobs_pending:remove(JTx, Type, JobId, STime), + clear_activity(JTx, Type, Seq), erlfdb:clear(Tx, Key), update_watch(JTx, Type), ok; |