diff --git a/pkg/workflows/wasm/host/logging_test.go b/pkg/workflows/wasm/host/logging_test.go index 8d4f97b9d9..8b23daa690 100644 --- a/pkg/workflows/wasm/host/logging_test.go +++ b/pkg/workflows/wasm/host/logging_test.go @@ -28,7 +28,7 @@ func TestLogRawMessage_PanicAndFatalLevelsDoNotCrashHost(t *testing.T) { entries := logs.All() require.Len(t, entries, 1) require.Equal(t, zapcore.ErrorLevel, entries[0].Level) - require.Equal(t, "boom", entries[0].Message) + require.Equal(t, "["+level+"] boom", entries[0].Message) }) } } diff --git a/pkg/workflows/wasm/host/module.go b/pkg/workflows/wasm/host/module.go index 3703d0533a..885ef8804e 100644 --- a/pkg/workflows/wasm/host/module.go +++ b/pkg/workflows/wasm/host/module.go @@ -1078,9 +1078,12 @@ func logRawMessage(logger logger.Logger, b []byte) error { logger.Warnw(sanitizedMsg, args...) case "error": logger.Errorw(sanitizedMsg, args...) - case "panic", "fatal": + case "panic": // The guest should never be able to panic/exit the host - logger.Errorw(sanitizedMsg, args...) + logger.Errorw("[panic] "+sanitizedMsg, args...) + case "fatal": + // The guest should never be able to panic/exit the host + logger.Errorw("[fatal] "+sanitizedMsg, args...) default: logger.Infow(sanitizedMsg, args...) }