Function MetadataUpdatesFromWorkContext

internal/jobexecutor/job_executor.go:71–81

MetadataUpdatesFromWorkContext returns the metadata updates stored in the work context, if any. When run on a non-work context, it returns nil, false.

(ctx context.Context)

//
// When run on a non-work context, it returns nil, false.
func MetadataUpdatesFromWorkContext(ctx context.Context) (map[string]any, bool) {
	metadataUpdates := ctx.Value(ContextKeyMetadataUpdates)
	if metadataUpdates == nil {
		return nil, false
	}
	typedMetadataUpdates, ok := metadataUpdates.(map[string]any)
	if !ok {
		return nil, false
	}
	return typedMetadataUpdates, true
}

type jobExecutorResult struct {
	Err             error