3524
}
3525
3526
>
executionContext := NewMutableContext(progressIntentCtx, n)
tree.go
3527
>
component, err := n.Component(executionContext, ComponentRef{})
3528
>
if err != nil {
3529
return false, err
3530
}
3531
3532
>
defer log.CapturePanic(n.logger, &retErr)
tree.go
3533
>
3534
>
archetypeTag := metrics.ArchetypeTag("")
3535
>
if name, ok := n.registry.ArchetypeDisplayName(n.ArchetypeID()); ok {
3536
>
archetypeTag = metrics.ArchetypeTag(name)
3537
>
}
3538
>
chasmTaskTypeTag := metrics.ChasmTaskTypeTag(registrableTask.fqType())
3539
>
metricsHandler := n.metricsHandler.WithTags(archetypeTag)
3540
>
3541
>
execErr := registrableTask.pureTaskExecuteFn(
3542
>
executionContext,
3543
>
component,
3544
>
taskAttributes,
3545
>
taskInstance,
3546
>
n.registry,
3547
>
)
3548
>
3549
>
metrics.ChasmPureTaskRequests.With(metricsHandler).Record(1, chasmTaskTypeTag)
3550
>
3551
>
if execErr != nil {
3552
metrics.ChasmPureTaskErrors.With(metricsHandler).Record(1, chasmTaskTypeTag)
3553
return true, execErr