448
archetypeID chasm.ArchetypeID,
449
lockPriority locks.Priority,
450
>
) (runID string, retErr error) {
cache.go
451
>
currentRelease, err := workflowCache.GetOrCreateCurrentExecution(
452
>
ctx,
453
>
shardContext,
454
>
namespace.ID(namespaceID),
455
>
workflowID,
456
>
archetypeID,
457
>
lockPriority,
458
>
)
459
>
if err != nil {
460
return "", err
461
}
462
>
defer func() { currentRelease(retErr) }()
cache.go
463
464
>
resp, err := shardContext.GetCurrentExecution(
cache.go
465
>
ctx,
466
>
&persistence.GetCurrentExecutionRequest{
467
>
ShardID: shardContext.GetShardID(),
468
>
NamespaceID: namespaceID,
469
>
WorkflowID: workflowID,
470
>
ArchetypeID: archetypeID,
471
>
},
472
>
)
473
>
if err != nil {
474
return "", err
475
}