fix: skip stopped worker protocol subscriptions
This commit is contained in:
@@ -380,6 +380,7 @@ Deno.test("Worker Console uses protocol observation events without transcript fe
|
|||||||
consolePage.includes("connectProtocolTransport") &&
|
consolePage.includes("connectProtocolTransport") &&
|
||||||
consolePage.includes("handleIncomingProtocolEvent") &&
|
consolePage.includes("handleIncomingProtocolEvent") &&
|
||||||
consolePage.includes("workspaceMultiplexer") &&
|
consolePage.includes("workspaceMultiplexer") &&
|
||||||
|
consolePage.includes('targetWorker.state === "stopped"') &&
|
||||||
consolePage.includes('topic: "worker_protocol"') &&
|
consolePage.includes('topic: "worker_protocol"') &&
|
||||||
!consolePage.includes("seenObservationEventIds") &&
|
!consolePage.includes("seenObservationEventIds") &&
|
||||||
consolePage.includes("createConsoleProjector") &&
|
consolePage.includes("createConsoleProjector") &&
|
||||||
|
|||||||
@@ -934,7 +934,7 @@
|
|||||||
token: number,
|
token: number,
|
||||||
target: ConsoleTarget,
|
target: ConsoleTarget,
|
||||||
) {
|
) {
|
||||||
if (!targetWorker) {
|
if (!targetWorker || targetWorker.state === "stopped") {
|
||||||
protocolState = "closed";
|
protocolState = "closed";
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user