MongoDB: Bulk Write Operation Error with '$type' Field in Elsa 3.0 Workflows

Question

Description: I encountered an issue when trying to run a workflow using MongoDB for persistence in my Elsa project. The error does not occur when using SQLite. Below are the details of my setup and the error message.

Error Message: Microsoft.AspNetCore.Diagnostics.DeveloperExceptionPageMiddleware[1] An unhandled exception has occurred while executing the request. MongoDB.Driver.MongoBulkWriteException1[Elsa.Workflows.Runtime.Entities.StoredTrigger]: A bulk write operation resulted in one or more errors. WriteErrors: [ { Category : "Uncategorized", Code : 52, Message : "The dollar ($) prefixed field '$type' in 'Payload.$type' is not valid for storage." } ]. at MongoDB.Driver.MongoCollectionImpl1.BulkWriteAsync(IClientSessionHandle session, IEnumerable`1 requests, BulkWriteOptions options, CancellationToken cancellationToken)



  
    net8.0
    8.0.0
    enable
    enable
    True
    C:
ugget rewrite project\JustAtestApp\Docs\ORVWorkflowAdminServer.xml
    true
    false
  
  
    True
  

  
    False
  

  
    
    
  

  
    <_WebToolingArtifacts Remove="Properties\launchSettings.json" />
    <_WebToolingArtifacts Remove="Properties\launchSettings_old.json" />

Program.cs:

using Elsa.Extensions;
using Elsa.MongoDb.Extensions;
using Elsa.MongoDb.Modules.Management;
using Elsa.MongoDb.Modules.Runtime;

var builder = WebApplication.CreateBuilder(args);

builder.Configuration
    .AddJsonFile("appsettings.json", optional: false, reloadOnChange: true)
    .AddJsonFile($"appsettings.{builder.Environment.EnvironmentName}.json", optional: true, reloadOnChange: true)
    .AddEnvironmentVariables();

builder.Services.AddElsa(elsa =>
{
    var configuration = builder.Configuration;
    elsa.UseMongoDb(configuration.GetConnectionString("MongoDb"));

    // Configure Management layer to use MongoDB.
    elsa.UseWorkflowManagement(management => management.UseMongoDb());

    // Configure Runtime layer to use MongoDB.
    elsa.UseWorkflowRuntime(runtime => runtime.UseMongoDb());

    // Default Identity features for authentication/authorization.
    elsa.UseIdentity(identity =>
    {
        identity.TokenOptions = options => options.SigningKey = "sufficiently-large-secret-signing-key"; // This key needs to be at least 256 bits long.
        identity.UseAdminUserProvider();
    });

    // Configure ASP.NET authentication/authorization.
    elsa.UseDefaultAuthentication(auth => auth.UseAdminApiKey());
    
    // Expose Elsa API endpoints.
    elsa.UseWorkflowsApi();
    
    // Setup a SignalR hub for real-time updates from the server.
    elsa.UseRealTimeWorkflows();
    
    // Enable C# workflow expressions
    elsa.UseCSharp();
    
    // Enable HTTP activities.
    elsa.UseHttp();
    
    // Use timer activities.
    elsa.UseScheduling();
    
    // Register custom activities from the application, if any.
    elsa.AddActivitiesFrom();
    
    // Register custom workflows from the application, if any.
    elsa.AddWorkflowsFrom();
});

// Configure CORS to allow designer app hosted on a different origin to invoke the APIs.
builder.Services.AddCors(cors => cors
    .AddDefaultPolicy(policy => policy
        .AllowAnyOrigin() // For demo purposes only. Use a specific origin instead.
        .AllowAnyHeader()
        .AllowAnyMethod()
        .WithExposedHeaders("*"))); // Required for Elsa Studio in order to support running workflows from the designer. Alternatively, you can use the `*` wildcard to expose all headers or `x-elsa-workflow-instance-id`.

// Add Health Checks.
builder.Services.AddHealthChecks();

// Build the web application.
var app = builder.Build();

// Configure web application's middleware pipeline.
app.UseCors();
app.UseRouting(); // Required for SignalR.
app.UseAuthentication();
app.UseAuthorization();
app.UseWorkflowsApi(); // Use Elsa API endpoints.
app.UseWorkflows(); // Use Elsa middleware to handle HTTP requests mapped to HTTP Endpoint activities.
app.UseWorkflowsSignalRHubs(); // Optional SignalR integration. Elsa Studio uses SignalR to receive real-time updates from the server.

// Map the health check endpoint.
app.MapHealthChecks("/health");

app.Run();

Steps to Reproduce:

Set up a new Elsa Server project with the provided ElsaServer.csproj and Program.cs files.
Configure MongoDB connection string in appsettings.json.
Run the application.

Create and run a new [Elsa Studio Project](https://v3.elsaworkflows.io/docs/installation/elsa-studio-blazorserver)

Create a new Workflow and try run the workflow

Additional Information: • The error does not occur when using SQLite for persistence. • The MongoDB server is running locally at mongodb://localhost:27017/workflow.

Expected Behavior: The workflow should execute without any errors.

Actual Behavior: A MongoBulkWriteException is thrown with the message: "The dollar ($) prefixed field '$type' in 'Payload.$type' is not valid for storage." Environment: • Elsa Version: 3.1.3 • Elsa.MongoDb 3.1.3 • .NET Version: 8.0.0

Elsa Server:

Elsa Studio

I tried Adding packages that I was missing, there could be something else I'm missing that I couldn't find in the documentation

MongoDB: Bulk Write Operation Error with '$type' Field in Elsa 3.0 Workflows

Answers (0)

Related Questions

MongoDB: Bulk Write Operation Error with &#39;$type&#39; Field in Elsa 3.0 Workflows

Answers (0)

Related Questions

MongoDB: Bulk Write Operation Error with '$type' Field in Elsa 3.0 Workflows