add print statements to cloudwatch metric task

Author: briancaffey

awscdk/app.py

@@ -38,4 +38,6 @@
 # CloudWatch Container Insights
 stack.node.apply_aspect(core.Tag("StackName", full_app_name))
 
+print(len(stack.node.children))
+
 app.synth()

backend/apps/core/management/commands/put_celery_cloudwatch_metrics.py

@@ -19,6 +19,7 @@ def active_and_reserved_tasks_by_queue_name(self, queue_name):
         and values are lists of active tasks for the worker
 
         """
+        print("inspecting celery queue")
         i = celery_app.control.inspect()
 
         active = i.active()
@@ -45,6 +46,7 @@ def active_and_reserved_tasks_by_queue_name(self, queue_name):
                     ]
                 )
 
+        print("connecting to redis")
         r = redis.Redis(
             host=settings.REDIS_SERVICE_HOST,
             port=6379,
@@ -58,13 +60,16 @@ def active_and_reserved_tasks_by_queue_name(self, queue_name):
         return active_count + reserved_count + queue_length
 
     def publish_queue_metrics(self, queue_names):
+        print("gathering queue data")
         metric_data = {
             queue_name: self.active_and_reserved_tasks_by_queue_name(
                 queue_name
             )
             for queue_name in queue_names
         }
+        print("sending cloudwatch data")
         if not settings.DEBUG:
+            print("connecting aws api")
             client = boto3.client('cloudwatch')
             client.put_metric_data(
                 Namespace=os.environ.get("FULL_APP_NAME", "FULL_APP_NAME"),
@@ -75,5 +80,5 @@ def publish_queue_metrics(self, queue_names):
             )
 
     def handle(self, *args, **options):
-
+        print("starting task")
         self.publish_queue_metrics(["default"])