fix context value retrieval

PeerDB-io · Dec 25, 2023 · 6ec47ae · 6ec47ae
1 parent 2332b6d
commit 6ec47ae
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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)
 	}