From 6ec47ae315a8457329668ec1e2a5fa1d790a8b58 Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj Date: Tue, 26 Dec 2023 01:29:24 +0530 Subject: [PATCH] fix context value retrieval --- flow/activities/flowable.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go index f6413c7ace..66a4a2033f 100644 --- a/flow/activities/flowable.go +++ b/flow/activities/flowable.go @@ -72,7 +72,7 @@ func (a *FlowableActivity) SetupMetadataTables(ctx context.Context, config *prot } defer connectors.CloseConnector(dstConn) - flowName := ctx.Value(shared.FlowNameKey).(string) + flowName, _ := ctx.Value(shared.FlowNameKey).(string) if err := dstConn.SetupMetadataTables(); err != nil { a.Alerter.LogFlowError(ctx, flowName, err) return fmt.Errorf("failed to setup metadata tables: %w", err) @@ -170,7 +170,7 @@ func (a *FlowableActivity) CreateNormalizedTable( setupNormalizedTablesOutput, err := conn.SetupNormalizedTables(config) if err != nil { - flowName := ctx.Value(shared.FlowNameKey).(string) + flowName, _ := ctx.Value(shared.FlowNameKey).(string) a.Alerter.LogFlowError(ctx, flowName, err) return nil, fmt.Errorf("failed to setup normalized tables: %w", err) }