From 2a4f6518b7a62038e18c5b2029c76f9c49d552cd Mon Sep 17 00:00:00 2001 From: yux0 Date: Fri, 12 Sep 2025 10:27:47 -0700 Subject: [PATCH] Log system worker fatal error --- service/worker/worker.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/service/worker/worker.go b/service/worker/worker.go index 9a29fb15680..8e7c65151c4 100644 --- a/service/worker/worker.go +++ b/service/worker/worker.go @@ -56,6 +56,9 @@ func (wm *workerManager) Start() { Identity: "temporal-system@" + wm.hostInfo.Identity(), // TODO: add dynamic config for worker options BackgroundActivityContext: headers.SetCallerType(context.Background(), headers.CallerTypeBackgroundHigh), + OnFatalError: func(err error) { + wm.logger.Error("Encounter fatal error on system worker.", tag.Error(err), tag.WorkerComponent(wm.hostInfo.Identity())) + }, } sdkClient := wm.sdkClientFactory.GetSystemClient() defaultWorker := wm.sdkClientFactory.NewWorker(sdkClient, primitives.DefaultWorkerTaskQueue, defaultWorkerOptions)