archetypeID chasm.ArchetypeID,
serializer serialization.Serializer,
currentRow, err := tx.LockCurrentExecutions(ctx, sqlplugin.CurrentExecutionsFilter{
ShardID: shardID,
NamespaceID: namespaceID,
WorkflowID: workflowID,
ArchetypeID: archetypeID,
})
if err != nil {
if err == sql.ErrNoRows {
// allow bypassing no current record