From 723b438bca0442e6b667247180342cd1c883ef11 Mon Sep 17 00:00:00 2001 From: John Sekar Date: Tue, 14 Nov 2017 01:30:19 -0500 Subject: [PATCH] Added verbose mode for updated message queue processing --- tests/test_sim.py | 2 ++ wc_rules/sim.py | 4 +++- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/tests/test_sim.py b/tests/test_sim.py index 584cc3e..25adbe6 100644 --- a/tests/test_sim.py +++ b/tests/test_sim.py @@ -27,6 +27,8 @@ def test_update_scheme(self): queries = [A(id='query1',b=True),A(id='query2',b=True)] queries[0].x.append(queries[1]) sim = SimulationState() + # This prints out each message when received + sim.verbose = False sim.add_as_graphquery(queries) # Test 1 diff --git a/wc_rules/sim.py b/wc_rules/sim.py index 9d24aae..be1f11e 100644 --- a/wc_rules/sim.py +++ b/wc_rules/sim.py @@ -25,6 +25,7 @@ def __init__(self,**kwargs): super().__init__(**kwargs) self.nodetypequery= NodeTypeQuery() self.update_message_queue = deque() + self.verbose = False def add_message(self,update_message): # appends to the right of deque @@ -38,7 +39,8 @@ def pop_message(self): def process_message(self,update_message): # processes and returns a list of messages - # print('processing message ',update_message.__str__()) + if self.verbose: + print('processing message ',update_message.__str__()) update_attr = update_message['update_attr'] update_type = update_message['update_type'] msgs = []