Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
Eventing: fixing indentation
Change-Id: I042a49b4b32e44017d92825b7dd3e9addbc82c3f
Reviewed-on: http://review.couchbase.org/c/testrunner/+/125101
Reviewed-by: <ankit.prabhu@couchbase.com>
Tested-by: vikas chaudhary <vikas.chaudhary@couchbase.com>
Reviewed-on: http://review.couchbase.org/c/testrunner/+/127419
Reviewed-by: Balakumaran G <balakumaran.gopal@couchbase.com>
  • Loading branch information
vikas-getconnect committed May 6, 2020
1 parent 68e7119 commit 6168d41
Showing 1 changed file with 17 additions and 17 deletions.
34 changes: 17 additions & 17 deletions pytests/eventing/eventing_base.py
Expand Up @@ -198,23 +198,23 @@ def verify_eventing_results(self, name, expected_dcp_mutations, doc_timer_events
# TODO : add this back when getEventProcessingStats works reliably for doc timer events as well
if not doc_timer_events:
count = 0
actual_dcp_mutations = self.getActualMutations(num_nodes, name, on_delete)

# This is required when binary data is involved where dcp_mutation will have process DCP_MUTATIONS
# but ignore it
# wait for eventing node to process dcp mutations
log.info("Number of (is Deleted: {0}) processed till now : {1}".format(on_delete, actual_dcp_mutations))
while actual_dcp_mutations != expected_dcp_mutations and count < 20:
self.sleep(timeout/20, message="Waiting for eventing to process all dcp mutations...")
count += 1
actual_dcp_mutations = self.getActualMutations(num_nodes, name, on_delete)
log.info("Number of onDelete? {0} processed till now : {1}".format(on_delete, actual_dcp_mutations))
if count == 20:
raise Exception(
"Eventing has not processed all the isDeleted: {0}. Current : {1} Expected : {2}".format(on_delete,
actual_dcp_mutations,
expected_dcp_mutations
))
actual_dcp_mutations = self.getActualMutations(num_nodes, name, on_delete)

# This is required when binary data is involved where dcp_mutation will have process DCP_MUTATIONS
# but ignore it
# wait for eventing node to process dcp mutations
log.info("Number of (is Deleted: {0}) processed till now : {1}".format(on_delete, actual_dcp_mutations))
while actual_dcp_mutations != expected_dcp_mutations and count < 20:
self.sleep(timeout/20, message="Waiting for eventing to process all dcp mutations...")
count += 1
actual_dcp_mutations = self.getActualMutations(num_nodes, name, on_delete)
log.info("Number of onDelete? {0} processed till now : {1}".format(on_delete, actual_dcp_mutations))
if count == 20:
raise Exception(
"Eventing has not processed all the isDeleted: {0}. Current : {1} Expected : {2}".format(on_delete,
actual_dcp_mutations,
expected_dcp_mutations
))
# wait for bucket operations to complete and verify it went through successfully
count = 0
stats_dst = self.rest.get_bucket_stats(bucket)
Expand Down

0 comments on commit 6168d41

Please sign in to comment.