Check error

cschleiden · cschleiden · commit de9dc480f0c6 · 2023-11-17T21:59:15.000-08:00
diff --git a/client/client.go b/client/client.go
@@ -67,7 +67,9 @@ func (c *Client) CreateWorkflowInstance(ctx context.Context, options WorkflowIns
 	defer span.End()
 
 	for _, propagator := range c.backend.ContextPropagators() {
-		propagator.Inject(ctx, metadata)
+		if err := propagator.Inject(ctx, metadata); err != nil {
+			return nil, fmt.Errorf("injecting context to propagate: %w", err)
+		}
 	}
 
 	startedEvent := history.NewPendingEvent(

Original file line number	Diff line number	Diff line change
`@@ -67,7 +67,9 @@ func (c *Client) CreateWorkflowInstance(ctx context.Context, options WorkflowIns`
`67`	`67`	`defer span.End()`
`68`	`68`
`69`	`69`	`for _, propagator := range c.backend.ContextPropagators() {`
`70`		`- propagator.Inject(ctx, metadata)`
	`70`	`+ if err := propagator.Inject(ctx, metadata); err != nil {`
	`71`	`+ return nil, fmt.Errorf("injecting context to propagate: %w", err)`
	`72`	`+ }`
`71`	`73`	`}`
`72`	`74`
`73`	`75`	`startedEvent := history.NewPendingEvent(`