Are database transactions supported in Elsa.Client.Services.IWorkflowDefinitionsApi?

[agalekseev]

We use Elsa 2.14.1 and calling Elsa.Client.Services.IWorkflowDefinitionsApi.SaveAsync endpoint (/v1/workflow-definitions/{workflowDefinitionVersionId}) to store dynamically generated workflow in ECR container connected to external DB (Postgres). But, sometimes Elsa's database loses "latest" version of a workflow definition, simply no record with "IsLatest" column set to true for a particular workflow.

Same issue with 2 concurrent users trying to update workflow definition with the same id. It seems, in general, that Elsa server does not use db transactions to save entities to db, nor isolates concurrent users, please, correct me if I'm wrong.

Is it possible to use transactional behavior in Elsa Server API somehow? Maybe some extension exists? Or does it need to be added manually during configuration as code hooks or configs?

[agalekseev]

code to reproduce (tested on Elsa image elsaworkflows/elsa-dashboard-and-server:sha-2c431f5)

using Elsa.Client;
using Elsa.Client.Extensions;
using Elsa.Client.Models;
using Microsoft.Extensions.DependencyInjection;

ServiceCollection serviceCollection = new();
serviceCollection.AddElsaClient(
    // connecting to a Docker container
    options => options.ServerUrl = new Uri("http://localhost:13000"));
var sp = serviceCollection.BuildServiceProvider();

var tasks = Enumerable
    .Range(1, 2)
    .Select(i =>
    {
        var threadNo = i.ToString();
        return new TaskFactory(
                TaskCreationOptions.LongRunning,
                TaskContinuationOptions.None)
            .StartNew(async () => await RunSaveLoop(threadNo));
    })
    .Select(t=> t.Result)
    .ToArray();

await Task.WhenAll(tasks);
return 0;

async Task RunSaveLoop(string id)
{
    await Task.Yield();
    while (true)
    {
        await SaveWorkflow(id);
    }
}

async Task SaveWorkflow(
    string id)
{
    Console.WriteLine($"Saving workflow in thread {id}");
    
    var request = new SaveWorkflowDefinitionRequest
    {
        WorkflowDefinitionId = "test definition",
        Name = "test definition",
        DisplayName = "test definition",
        Publish = true,
        Activities = new List<ActivityDefinition>(),
        Connections = new List<ConnectionDefinition>(),
    };
    var elsaClient = sp.GetRequiredService<IElsaClient>();

    try
    {
        var response = await elsaClient
            .WorkflowDefinitions
            .SaveAsync(request);
        
        Console.WriteLine($"Saved workflow in thread {id}");
    }
    catch (Exception e)
    {
        Console.WriteLine($"Thread {id} failed: {e.Message}");
        throw;
    }
}