Add event key to queue depths

Author: jordaneb

README.md

@@ -213,7 +213,7 @@ To start a worker:
 - The `--rate_limit` flag is optional, and will default to `1`. It is the minimum number of seconds that must have elapsed before a subsequent job can be run.
 
 ##### manage.py queue_depth
-If you'd like to check your queue depth from the command line, you can run `manage.py queue_depth [queue_name]` and any
+If you'd like to check your queue depth from the command line, you can run `manage.py queue_depth [queue_name [queue_name ...]]` and any
 jobs in the "NEW" or "READY" states will be returned.
 
 **Important:** If you misspell or provide a queue name which does not have any jobs, a depth of 0 will always be returned.

django_dbq/management/commands/queue_depth.py

@@ -13,14 +13,15 @@ def handle(self, *args, **options):
         queue_names = options["queue_name"]
         queue_depths = Job.get_queue_depths()
 
+        queue_depths_string = " ".join(
+            [
+                "{queue_name}={queue_depth}".format(
+                    queue_name=queue_name, queue_depth=queue_depths.get(queue_name, 0),
+                )
+                for queue_name in queue_names
+            ]
+        )
+
         self.stdout.write(
-            " ".join(
-                [
-                    "{queue_name}={queue_depth}".format(
-                        queue_name=queue_name,
-                        queue_depth=queue_depths.get(queue_name, 0),
-                    )
-                    for queue_name in queue_names
-                ]
-            )
+            "event=queue_depths {queue_depths}".format(queue_depths=queue_depths_string)
         )

django_dbq/tests.py

@@ -117,7 +117,7 @@ def test_queue_depth(self):
         stdout = StringIO()
         call_command("queue_depth", stdout=stdout)
         output = stdout.getvalue()
-        self.assertEqual(output.strip(), "default=2")
+        self.assertEqual(output.strip(), "event=queue_depths default=2")
 
     def test_queue_depth_multiple_queues(self):
 
@@ -136,13 +136,13 @@ def test_queue_depth_multiple_queues(self):
         stdout = StringIO()
         call_command("queue_depth", queue_name=("default", "testqueue",), stdout=stdout)
         output = stdout.getvalue()
-        self.assertEqual(output.strip(), "default=2 testqueue=2")
+        self.assertEqual(output.strip(), "event=queue_depths default=2 testqueue=2")
 
     def test_queue_depth_for_queue_with_zero_jobs(self):
         stdout = StringIO()
         call_command("queue_depth", queue_name=("otherqueue",), stdout=stdout)
         output = stdout.getvalue()
-        self.assertEqual(output.strip(), "otherqueue=0")
+        self.assertEqual(output.strip(), "event=queue_depths otherqueue=0")
 
 
 @freezegun.freeze_time()