workflows
workflows.WithTaskSpan
Copy
Ask AI
type Task struct{}
func (t *Task) Execute(ctx context.Context) error {
err := workflows.WithTaskSpan(ctx, "Database insert", func(ctx context.Context) error {
// Do something
return nil
})
if err != nil {
return fmt.Errorf("failed to insert into database: %w", err)
}
return nil
}
Copy
Ask AI
workflows.WithTaskSpan(
ctx context.Context,
name string,
f func(ctx context.Context) error,
) error
Wrap a function with a tracing span.
Parameters
The name of the span
The function to wrap
Returns
An error if any.
Copy
Ask AI
type Task struct{}
func (t *Task) Execute(ctx context.Context) error {
err := workflows.WithTaskSpan(ctx, "Database insert", func(ctx context.Context) error {
// Do something
return nil
})
if err != nil {
return fmt.Errorf("failed to insert into database: %w", err)
}
return nil
}
Was this page helpful?
Copy
Ask AI
type Task struct{}
func (t *Task) Execute(ctx context.Context) error {
err := workflows.WithTaskSpan(ctx, "Database insert", func(ctx context.Context) error {
// Do something
return nil
})
if err != nil {
return fmt.Errorf("failed to insert into database: %w", err)
}
return nil
}
Assistant
Responses are generated using AI and may contain mistakes.