Function assertNotCurrentExecution

common/persistence/sql/execution_util.go:940–964

(
	ctx context.Context,
	tx sqlplugin.Tx,
	shardID int32,
	namespaceID primitives.UUID,
	workflowID string,
	runID primitives.UUID,
	archetypeID chasm.ArchetypeID,
	serializer serialization.Serializer,
)

}

func assertNotCurrentExecution(
	ctx context.Context,
	tx sqlplugin.Tx,
	shardID int32,
	namespaceID primitives.UUID,
	workflowID string,
	runID primitives.UUID,
	archetypeID chasm.ArchetypeID,
	serializer serialization.Serializer,
) error {
	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
			return nil
		}
		return serviceerror.NewUnavailablef("assertCurrentExecution failed. Unable to load current record. Error: %v", err)
	}
	return assertRunIDMismatch(runID, currentRow, serializer)
}

func assertRunIDAndUpdateCurrentExecution(
	ctx context.Context,