(
execution: PausedExecution,
source: "execute" | "execute_action" | "resume" | "browser_resume",
)
| 1118 | .pipe(Effect.catchCause(() => Effect.succeed(null))) ?? Effect.succeed(null); |
| 1119 | |
| 1120 | const formatPausedModelResult = ( |
| 1121 | execution: PausedExecution, |
| 1122 | source: "execute" | "execute_action" | "resume" | "browser_resume", |
| 1123 | ): Effect.Effect<McpToolResult> => |
| 1124 | Effect.gen(function* () { |
| 1125 | const deadline = pauseDeadline(); |
| 1126 | yield* Effect.annotateCurrentSpan({ |
| 1127 | "mcp.execute.paused": true, |
| 1128 | "mcp.execute.paused_execution_id": execution.id, |
| 1129 | "mcp.execute.pause_source": source, |
| 1130 | }); |
| 1131 | yield* onExecutionPaused(execution.id, deadline); |
| 1132 | return toMcpPausedResult(formatPausedExecution(execution, { deadline })); |
| 1133 | }); |
| 1134 | |
| 1135 | const resolveParentSpan = (): Tracer.AnySpan | undefined => { |
| 1136 | const ps = config.parentSpan; |
no test coverage detected