Pipeline debugging support added

oahu_config.py

@@ -1,4 +1,5 @@
 import oahu.config
+from oahu import debugging
 from oahu import mongodb_driver as driver
 from oahu import trigger_definition
 from oahu import pipeline_callback
@@ -22,7 +23,8 @@ class Config(oahu.config.Config):
         by_request = trigger_definition.TriggerDefinition("request-id",
                                                       ["_context_request_id", ],
                                                       criteria.Inactive(60),
-                                                      self.callback)
+                                                      self.callback,
+                                                      debug=True)
 
         # This trigger requires a Trait called "when_date" which is
         # the date-only portion of the "when" trait. We will create
@@ -32,7 +34,8 @@ class Config(oahu.config.Config):
                               ["payload/instance_id", "audit_bucket"],
                               criteria.EndOfDayExists(
                                     'compute.instance.exists'),
-                              self.callback)
+                              self.callback, debug=True,
+                              dumper=debugging.DetailedDumper())
 
         triggers = [by_request, instance_usage]
 

screenrc

@@ -11,10 +11,10 @@ stuff "cd git/quincy/quincy; gunicorn --log-file=- api:api\r"
 screen -t expired bash
 stuff "pipeline expired \".|oahu_config:Config\" --polling_rate=20\r"
 screen -t ready1 bash
-stuff "pipeline ready \".|oahu_config:Config\" --polling_rate=1\r"
+stuff "pipeline ready \".|oahu_config:Config\" --polling_rate=20\r"
 screen -t ready2 bash
-stuff "pipeline ready \".|oahu_config:Config\" --polling_rate=1\r"
+stuff "pipeline ready \".|oahu_config:Config\" --polling_rate=20\r"
 screen -t completed bash
-stuff "pipeline completed \".|oahu_config:Config\" --polling_rate=2\r"
+stuff "pipeline completed \".|oahu_config:Config\" --polling_rate=20\r"
 screen -t bash bash
 stuff "klugman events -h\r"

shoebox.conf

@@ -1,6 +1,7 @@
 [global]
 verbose = True
 debug = True
+update_timer = 10
 
 [event_worker]
 pidfile = yagi_event_worker.pid
@@ -13,11 +14,11 @@ user = guest
 password = guest
 port = 5672
 vhost = /
-#poll_delay = 1
+poll_delay = 0.5
 
 [logging]
 logfile = yagi.log
-default_level = WARN
+default_level = INFO
 
 [consumers]
 queues = monitor.info