feat(queues): Add Python sentry.op values for queues

javascript/sentry-conventions/src/op.ts

@@ -180,6 +180,46 @@ export const MESSAGING_QUEUE_PROCESS_SPAN_OP = 'queue.process';
  */
 export const MESSAGING_QUEUE_SETTLE_SPAN_OP = 'queue.settle';
 
+/**
+ * Publishing a message to an arq queue.
+ */
+export const MESSAGING_QUEUE_SUBMIT_ARQ_SPAN_OP = 'queue.submit.arq';
+
+/**
+ * Processing a message from an arq queue.
+ */
+export const MESSAGING_QUEUE_TASK_ARQ_SPAN_OP = 'queue.task.arq';
+
+/**
+ * Publishing a message to a Celery broker.
+ */
+export const MESSAGING_QUEUE_SUBMIT_CELERY_SPAN_OP = 'queue.submit.celery';
+
+/**
+ * Processing a message from a Celery queue.
+ */
+export const MESSAGING_QUEUE_TASK_CELERY_SPAN_OP = 'queue.task.celery';
+
+/**
+ * Processing a message from a Dramatiq queue.
+ */
+export const MESSAGING_QUEUE_TASK_DRAMATIQ_SPAN_OP = 'queue.task.dramatiq';
+
+/**
+ * Publishing a message to a Huey instance.
+ */
+export const MESSAGING_QUEUE_SUBMIT_HUEY_SPAN_OP = 'queue.submit.huey';
+
+/**
+ * Processing a message from a Huey instance.
+ */
+export const MESSAGING_QUEUE_TASK_HUEY_SPAN_OP = 'queue.task.huey';
+
+/**
+ * Processing a message from an RQ queue.
+ */
+export const MESSAGING_QUEUE_TASK_RQ_SPAN_OP = 'queue.task.rq';
+
 // Path: model/op/mobile.json
 // Name: mobile
 

model/description/messaging.json

@@ -4,7 +4,22 @@
     {
       "name": "Queue",
       "brief": "Operations that represent working with message queues, including publishing, receiving, processing, and settling messages.",
-      "ops": ["queue", "queue.publish", "queue.create", "queue.receive", "queue.process", "queue.settle"],
+      "ops": [
+        "queue",
+        "queue.publish",
+        "queue.create",
+        "queue.receive",
+        "queue.process",
+        "queue.settle",
+        "queue.submit.arq",
+        "queue.task.arq",
+        "queue.submit.celery",
+        "queue.task.celery",
+        "queue.task.dramatiq",
+        "queue.submit.huey",
+        "queue.task.huey",
+        "queue.task.rq"
+      ],
       "templates": ["{{messaging.destination.name}}"],
       "examples": ["order-events"]
     }

model/op/messaging.json

@@ -25,6 +25,38 @@
     {
       "name": "queue.settle",
       "description": "Settling a message, e.g. acknowledging or rejecting it."
+    },
+    {
+      "name": "queue.submit.arq",
+      "description": "Publishing a message to an arq queue."
+    },
+    {
+      "name": "queue.task.arq",
+      "description": "Processing a message from an arq queue."
+    },
+    {
+      "name": "queue.submit.celery",
+      "description": "Publishing a message to a Celery broker."
+    },
+    {
+      "name": "queue.task.celery",
+      "description": "Processing a message from a Celery queue."
+    },
+    {
+      "name": "queue.task.dramatiq",
+      "description": "Processing a message from a Dramatiq queue."
+    },
+    {
+      "name": "queue.submit.huey",
+      "description": "Publishing a message to a Huey instance."
+    },
+    {
+      "name": "queue.task.huey",
+      "description": "Processing a message from a Huey instance."
+    },
+    {
+      "name": "queue.task.rq",
+      "description": "Processing a message from an RQ queue."
     }
   ]
 }

rust/src/op.rs

@@ -140,6 +140,30 @@ pub const MESSAGING_QUEUE_PROCESS_SPAN_OP: &str = "queue.process";
 /// Settling a message, e.g. acknowledging or rejecting it.
 pub const MESSAGING_QUEUE_SETTLE_SPAN_OP: &str = "queue.settle";
 
+/// Publishing a message to an arq queue.
+pub const MESSAGING_QUEUE_SUBMIT_ARQ_SPAN_OP: &str = "queue.submit.arq";
+
+/// Processing a message from an arq queue.
+pub const MESSAGING_QUEUE_TASK_ARQ_SPAN_OP: &str = "queue.task.arq";
+
+/// Publishing a message to a Celery broker.
+pub const MESSAGING_QUEUE_SUBMIT_CELERY_SPAN_OP: &str = "queue.submit.celery";
+
+/// Processing a message from a Celery queue.
+pub const MESSAGING_QUEUE_TASK_CELERY_SPAN_OP: &str = "queue.task.celery";
+
+/// Processing a message from a Dramatiq queue.
+pub const MESSAGING_QUEUE_TASK_DRAMATIQ_SPAN_OP: &str = "queue.task.dramatiq";
+
+/// Publishing a message to a Huey instance.
+pub const MESSAGING_QUEUE_SUBMIT_HUEY_SPAN_OP: &str = "queue.submit.huey";
+
+/// Processing a message from a Huey instance.
+pub const MESSAGING_QUEUE_TASK_HUEY_SPAN_OP: &str = "queue.task.huey";
+
+/// Processing a message from an RQ queue.
+pub const MESSAGING_QUEUE_TASK_RQ_SPAN_OP: &str = "queue.task.rq";
+
 // Path: model/op/mobile.json
 // Name: mobile