ReadModelOutboxDrainerJob.ExecuteAsync

// Id: #35581
using Suno.Assets.ReadModel;

var readModelOutboxDrainerJob = Activate<ReadModelOutboxDrainerJob>();
await readModelOutboxDrainerJob.ExecuteAsync();

Parameters

RecurringJobId
"read-model-outbox-drainer"
Time
1789599543
CurrentCulture
""
CurrentUICulture
""

State

09/16/2026 19:59:06 (+576ms) Failed

An exception occurred during performance of the job.

System.InvalidOperationException (suno-assets-backoffice-api-6cf77569bf-gfc6k:1)

An exception has been raised that is likely due to a transient failure.

System.InvalidOperationException: An exception has been raised that is likely due to a transient failure.
 ---> Npgsql.PostgresException (0x80004005): 53300: remaining connection slots are reserved for roles with privileges of the "pg_use_reserved_connections" role
   at Npgsql.Internal.NpgsqlConnector.ReadMessageLong(Boolean async, DataRowLoadingMode dataRowLoadingMode, Boolean readingNotifications, Boolean isReadingPrependedMessage)
   at System.Runtime.CompilerServices.PoolingAsyncValueTaskMethodBuilder`1.StateMachineBox`1.System.Threading.Tasks.Sources.IValueTaskSource<TResult>.GetResult(Int16 token)
   at Npgsql.Internal.NpgsqlConnector.<Open>g__OpenCore|209_0(NpgsqlConnector conn, String username, SslMode sslMode, GssEncryptionMode gssEncMode, NpgsqlTimeout timeout, Boolean async, CancellationToken cancellationToken)
   at Npgsql.Internal.NpgsqlConnector.Open(NpgsqlTimeout timeout, Boolean async, CancellationToken cancellationToken)
   at Npgsql.PoolingDataSource.OpenNewConnector(NpgsqlConnection conn, NpgsqlTimeout timeout, Boolean async, CancellationToken cancellationToken)
   at Npgsql.PoolingDataSource.<Get>g__RentAsync|33_0(NpgsqlConnection conn, NpgsqlTimeout timeout, Boolean async, CancellationToken cancellationToken)
   at Npgsql.NpgsqlConnection.<Open>g__OpenAsync|42_0(Boolean async, CancellationToken cancellationToken)
   at Microsoft.EntityFrameworkCore.Storage.RelationalConnection.OpenInternal(Boolean errorsExpected)
   at Microsoft.EntityFrameworkCore.Storage.RelationalConnection.BeginTransaction(IsolationLevel isolationLevel)
   at Npgsql.EntityFrameworkCore.PostgreSQL.Storage.Internal.NpgsqlExecutionStrategy.Execute[TState,TResult](TState state, Func`3 operation, Func`3 verifySucceeded)
  Exception data:
    Severity: FATAL
    SqlState: 53300
    MessageText: remaining connection slots are reserved for roles with privileges of the "pg_use_reserved_connections" role
    File: postinit.c
    Line: 997
    Routine: InitPostgres
   --- End of inner exception stack trace ---
   at Npgsql.EntityFrameworkCore.PostgreSQL.Storage.Internal.NpgsqlExecutionStrategy.Execute[TState,TResult](TState state, Func`3 operation, Func`3 verifySucceeded)
   at Saf.EntityFrameworkCore.Uow.DbContextEfCoreTransactionStrategy.CreateDbContext[TDbContext](String connectionString, IDbContextResolver dbContextResolver) in /src/foundation/Saf.EntityFrameworkCore/EntityFrameworkCore/Uow/DbContextEfCoreTransactionStrategy.cs:line 106
   at Saf.EntityFrameworkCore.Uow.EfCoreUnitOfWork.GetOrCreateDbContext[TDbContext](Nullable`1 multiTenancySide, String name) in /src/foundation/Saf.EntityFrameworkCore/EntityFrameworkCore/Uow/EfCoreUnitOfWork.cs:line 171
   at Saf.EntityFrameworkCore.Repositories.EfCoreRepositoryBase`3.GetDbQueryTable() in /src/foundation/Saf.EntityFrameworkCore/EntityFrameworkCore/Repositories/EfCoreRepositoryBaseOfTEntityAndTPrimaryKey.cs:line 79
   at Saf.EntityFrameworkCore.Repositories.EfCoreRepositoryBase`3.GetQueryable() in /src/foundation/Saf.EntityFrameworkCore/EntityFrameworkCore/Repositories/EfCoreRepositoryBaseOfTEntityAndTPrimaryKey.cs:line 93
   at Suno.Assets.ReadModel.ReadModelOutboxDrainerJob.DrainOnceAsync() in /src/src/Suno.Assets.Application/ReadModel/ReadModelOutboxDrainerJob.cs:line 152
   at Suno.Assets.ReadModel.ReadModelOutboxDrainerJob.ExecuteAsync() in /src/src/Suno.Assets.Application/ReadModel/ReadModelOutboxDrainerJob.cs:line 135
   at InvokeStub_TaskAwaiter.GetResult(Object, Object, IntPtr*)
   at System.Reflection.MethodBaseInvoker.InvokeWithNoArgs(Object obj, BindingFlags invokeAttr)

+1.683s Processing

Server:
suno-assets-backoffice-api-6cf77569bf-gfc6k:1
Worker:
29357cf7

+36ms Enqueued

Triggered by recurring job scheduler

09/16/2026 19:59:03 Created