TheArchive/zitadel
1
0
Fork 0
mirror of https://github.com/zitadel/zitadel.git synced 2024-12-13 19:44:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(scheduler): add span to trigger method (#6513)

Browse Source
This commit is contained in:
Silvan 2023-09-07 10:59:44 +02:00 committed by adlerhurst
parent f72560291e
commit 2d75576864
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/eventstore/handler/handler_projection.go
View File

@ -13,6 +13,7 @@ import (
"github.com/zitadel/zitadel/internal/api/call" "github.com/zitadel/zitadel/internal/api/call"
"github.com/zitadel/zitadel/internal/eventstore" "github.com/zitadel/zitadel/internal/eventstore"
"github.com/zitadel/zitadel/internal/repository/pseudo" "github.com/zitadel/zitadel/internal/repository/pseudo"
"github.com/zitadel/zitadel/internal/telemetry/tracing"
) )
const ( const (
@ -141,6 +142,9 @@ func (h *ProjectionHandler) Trigger(ctx context.Context, instances ...string) co
// If a bulk action was executed, the call timestamp in context will be reset for subsequent queries. // If a bulk action was executed, the call timestamp in context will be reset for subsequent queries.
// The returned context is never nil. It is either the original context or an updated context. // The returned context is never nil. It is either the original context or an updated context.
func (h *ProjectionHandler) TriggerErr(ctx context.Context, instances ...string) (outCtx context.Context, err error) { func (h *ProjectionHandler) TriggerErr(ctx context.Context, instances ...string) (outCtx context.Context, err error) {
ctx, span := tracing.NewSpan(ctx)
defer span.EndWithError(err)
instances = triggerInstances(ctx, instances) instances = triggerInstances(ctx, instances)
defer func() { defer func() {
outCtx = call.ResetTimestamp(ctx) outCtx = call.ResetTimestamp(ctx)