Fix merge of 27f5067c and aca6a459

1 files changed, 6 insertions, 1 deletions

diff --git a/src/couch_replicator/test/couch_replicator_compact_tests.erl b/src/couch_replicator/test/couch_replicator_compact_tests.erl
index c99335d3d..3c9fb090f 100644
--- a/src/couch_replicator/test/couch_replicator_compact_tests.erl
+++ b/src/couch_replicator/test/couch_replicator_compact_tests.erl
@@ -148,7 +148,7 @@ wait_for_replicator(RepId) ->
 
 wait_for_task_status() ->
     test_util:wait(fun() ->
-        case couch_task_status:all() of
+        case replication_tasks() of
             [] ->
                 wait;
             Tasks ->
@@ -156,6 +156,11 @@ wait_for_task_status() ->
         end
     end).
 
+replication_tasks() ->
+    lists:filter(fun(P) ->
+        couch_util:get_value(type, P) =:= replication
+    end, couch_task_status:all()).
+
 should_cancel_replication(RepId, RepPid) ->
     ?_assertNot(begin
         ok = couch_replicator_scheduler:remove_job(RepId),