We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6da5e7a commit c2e859bCopy full SHA for c2e859b
apps/webapp/app/v3/marqs/sharedQueueConsumer.server.ts
@@ -1122,15 +1122,6 @@ export class SharedQueueConsumer {
1122
"emitResumeAfterDependencyWithAck",
1123
async (span) => {
1124
try {
1125
- const sockets = await this.#startActiveSpan("getCoordinatorSockets", async (span) => {
1126
- const sockets = await socketIo.coordinatorNamespace.fetchSockets();
1127
-
1128
- span.setAttribute("socket_count", sockets.length);
1129
1130
- return sockets;
1131
- });
1132
1133
1134
span.setAttribute("attempt_id", resumableAttempt.id);
1135
span.setAttribute(
1136
"timeout_in_ms",
0 commit comments