[couchdb] branch add-user-to-active-tasks-for-replicator created (now 43da3ea)

[va...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

vatamane pushed a change to branch add-user-to-active-tasks-for-replicator
in repository https://gitbox.apache.org/repos/asf/couchdb.git.


      at 43da3ea  Properly initialize `user` in replication job's state

This branch includes the following new commits:

     new 43da3ea  Properly initialize `user` in replication job's state

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: Properly initialize `user` in replication job's state

[va...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

vatamane pushed a commit to branch add-user-to-active-tasks-for-replicator
in repository https://gitbox.apache.org/repos/asf/couchdb.git

commit 43da3ea94c55505b59fbc5447660a153e7d8994a
Author: Nick Vatamaniuc <va...@apache.org>
AuthorDate: Tue Oct 6 17:48:07 2020 -0400

    Properly initialize `user` in replication job's state
    
    This value is emitted in _active_tasks and was previously emitting `null`
    values from the state record's defaults.
---
 src/couch_replicator/src/couch_replicator_job.erl | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/couch_replicator/src/couch_replicator_job.erl b/src/couch_replicator/src/couch_replicator_job.erl
index eaa661e..e13fb11 100644
--- a/src/couch_replicator/src/couch_replicator_job.erl
+++ b/src/couch_replicator/src/couch_replicator_job.erl
@@ -947,7 +947,8 @@ init_state(#{} = Job, #{} = JobData) ->
         ?SOURCE := Src0,
         ?TARGET := Tgt,
         ?START_TIME := StartTime,
-        ?OPTIONS := Options0
+        ?OPTIONS := Options0,
+        ?REP_USER := User
     } = Rep,
 
     % Optimize replication parameters if last time the jobs crashed because it
@@ -1013,7 +1014,8 @@ init_state(#{} = Job, #{} = JobData) ->
         stats_timer = nil,
         doc_id = DocId,
         db_name = DbName,
-        db_uuid = DbUUID
+        db_uuid = DbUUID,
+        user = User
     },
     start_checkpoint_timer(State).