Github/temporal
1
0
Fork 0
mirror of https://github.com/temporalio/temporal.git synced 2026-08-30 18:41:49 -07:00
Code Issues Packages Projects Releases Wiki Activity

Bind CHASM completion logger at construction

Browse Source
This commit is contained in:
Stephan Behnke
2026-08-24 12:40:34 -07:00
parent 0f2f1ee37f
commit 5ebf373582
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
chasm/lib/callback/invocable_outbound.go
View File

@@ -42,9 +42,8 @@ func (n invocableOutbound) Invoke(
task *callbackspb.InvocationTask,
taskAttr chasm.TaskAttributes,
) invocationResult {
logger := log.With(h.logger, tag.ComponentNexusCompletion)
if h.httpTraceProvider != nil {
traceLogger := log.With(logger,
traceLogger := log.With(h.logger,
tag.WorkflowNamespace(ns.Name().String()),
tag.Operation("CompleteNexusOperation"),
tag.Destination(taskAttr.Destination),
@@ -79,7 +78,7 @@ func (n invocableOutbound) Invoke(
if err != nil {
retryable := isRetryableCallError(err)
logger.Error("Callback request failed", tag.Error(err), tag.Bool("retryable", retryable))
h.logger.Error("Callback request failed", tag.Error(err), tag.Bool("retryable", retryable))
if retryable {
return invocationResultRetry{err}
}

3
chasm/lib/callback/tasks.go
View File

@@ -8,6 +8,7 @@ import (
"go.temporal.io/server/chasm"
callbackspb "go.temporal.io/server/chasm/lib/callback/gen/callbackpb/v1"
"go.temporal.io/server/common/log"
"go.temporal.io/server/common/log/tag"
"go.temporal.io/server/common/metrics"
"go.temporal.io/server/common/namespace"
commonnexus "go.temporal.io/server/common/nexus"
@@ -97,7 +98,7 @@ func newInvocationTaskHandler(opts invocationTaskHandlerOptions) *invocationTask
config: opts.Config,
namespaceRegistry: opts.NamespaceRegistry,
metricsHandler: opts.MetricsHandler,
logger: opts.Logger,
logger: log.With(opts.Logger, tag.ComponentNexusCompletion),
httpCallerProvider: opts.HTTPCallerProvider,
httpTraceProvider: opts.HTTPTraceProvider,
historyClient: opts.HistoryClient,