fix: annotate Effect log metadata (#27093)
This commit is contained in:
@@ -145,7 +145,7 @@ export const layer = Layer.effect(
|
|||||||
)
|
)
|
||||||
}
|
}
|
||||||
}).pipe(
|
}).pipe(
|
||||||
Effect.tapCause((cause) => Effect.logError("failed to run data migrations", { cause })),
|
Effect.tapCause((cause) => Effect.logError("failed to run data migrations").pipe(Effect.annotateLogs("cause", cause))),
|
||||||
Effect.ignore,
|
Effect.ignore,
|
||||||
Effect.forkScoped,
|
Effect.forkScoped,
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -37,7 +37,7 @@ export const layer = Layer.effect(
|
|||||||
|
|
||||||
const run = Effect.gen(function* () {
|
const run = Effect.gen(function* () {
|
||||||
const ctx = yield* InstanceState.context
|
const ctx = yield* InstanceState.context
|
||||||
yield* Effect.logInfo("bootstrapping", { directory: ctx.directory })
|
yield* Effect.logInfo("bootstrapping").pipe(Effect.annotateLogs("directory", ctx.directory))
|
||||||
// everything depends on config so eager load it for nice traces
|
// everything depends on config so eager load it for nice traces
|
||||||
yield* config.get()
|
yield* config.get()
|
||||||
// Plugin can mutate config so it has to be initialized before anything else.
|
// Plugin can mutate config so it has to be initialized before anything else.
|
||||||
|
|||||||
@@ -156,7 +156,9 @@ export const layer: Layer.Layer<Service, never, Project.Service | InstanceBootst
|
|||||||
Effect.gen(function* () {
|
Effect.gen(function* () {
|
||||||
const exit = yield* Deferred.await(item[1].deferred).pipe(Effect.exit)
|
const exit = yield* Deferred.await(item[1].deferred).pipe(Effect.exit)
|
||||||
if (Exit.isFailure(exit)) {
|
if (Exit.isFailure(exit)) {
|
||||||
yield* Effect.logWarning("instance dispose failed", { key: item[0], cause: exit.cause })
|
yield* Effect.logWarning("instance dispose failed").pipe(
|
||||||
|
Effect.annotateLogs({ key: item[0], cause: exit.cause }),
|
||||||
|
)
|
||||||
yield* removeEntry(item[0], item[1])
|
yield* removeEntry(item[0], item[1])
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -177,7 +177,7 @@ export const layer: Layer.Layer<Service, never, AppFileSystem.Service | HttpClie
|
|||||||
yield* invalidate
|
yield* invalidate
|
||||||
}),
|
}),
|
||||||
).pipe(
|
).pipe(
|
||||||
Effect.tapCause((cause) => Effect.logError("Failed to fetch models.dev", { cause })),
|
Effect.tapCause((cause) => Effect.logError("Failed to fetch models.dev").pipe(Effect.annotateLogs("cause", cause))),
|
||||||
Effect.ignore,
|
Effect.ignore,
|
||||||
)
|
)
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -169,7 +169,9 @@ export const layer = Layer.effect(
|
|||||||
).pipe(
|
).pipe(
|
||||||
Effect.asVoid,
|
Effect.asVoid,
|
||||||
Effect.catchCause((cause) =>
|
Effect.catchCause((cause) =>
|
||||||
Effect.logWarning("failed to materialize reference repository", { name: reference.name, cause }),
|
Effect.logWarning("failed to materialize reference repository").pipe(
|
||||||
|
Effect.annotateLogs({ name: reference.name, cause }),
|
||||||
|
),
|
||||||
),
|
),
|
||||||
),
|
),
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -299,7 +299,9 @@ export const sessionHandlers = HttpApiBuilder.group(InstanceHttpApi, "session",
|
|||||||
yield* promptSvc.prompt({ ...ctx.payload, sessionID: ctx.params.sessionID }).pipe(
|
yield* promptSvc.prompt({ ...ctx.payload, sessionID: ctx.params.sessionID }).pipe(
|
||||||
Effect.catchCause((cause) =>
|
Effect.catchCause((cause) =>
|
||||||
Effect.gen(function* () {
|
Effect.gen(function* () {
|
||||||
yield* Effect.logError("prompt_async failed", { sessionID: ctx.params.sessionID, cause })
|
yield* Effect.logError("prompt_async failed").pipe(
|
||||||
|
Effect.annotateLogs({ sessionID: ctx.params.sessionID, cause }),
|
||||||
|
)
|
||||||
yield* bus.publish(Session.Event.Error, {
|
yield* bus.publish(Session.Event.Error, {
|
||||||
sessionID: ctx.params.sessionID,
|
sessionID: ctx.params.sessionID,
|
||||||
error: new NamedError.Unknown({ message: Cause.pretty(cause) }).toObject(),
|
error: new NamedError.Unknown({ message: Cause.pretty(cause) }).toObject(),
|
||||||
|
|||||||
Reference in New Issue
Block a user