From 6168d41e662b2c8d7aab10e4568eddb82b0ef67a Mon Sep 17 00:00:00 2001 From: vikas chaudhary Date: Tue, 7 Apr 2020 12:08:01 +0530 Subject: [PATCH] Eventing: fixing indentation Change-Id: I042a49b4b32e44017d92825b7dd3e9addbc82c3f Reviewed-on: http://review.couchbase.org/c/testrunner/+/125101 Reviewed-by: Tested-by: vikas chaudhary Reviewed-on: http://review.couchbase.org/c/testrunner/+/127419 Reviewed-by: Balakumaran G --- pytests/eventing/eventing_base.py | 34 +++++++++++++++---------------- 1 file changed, 17 insertions(+), 17 deletions(-) diff --git a/pytests/eventing/eventing_base.py b/pytests/eventing/eventing_base.py index 13dae6afed..3fa7ff14f9 100644 --- a/pytests/eventing/eventing_base.py +++ b/pytests/eventing/eventing_base.py @@ -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)