IntegrationHealthCheckQueuedOrRunningTask.ProcessRecurringAsync

// Job ID: #7538435
using EkolPY.Integration.Manager.Tasks;

var integrationHealthCheckQueuedOrRunningTask = Activate<IntegrationHealthCheckQueuedOrRunningTask>();
await integrationHealthCheckQueuedOrRunningTask.ProcessRecurringAsync(
    null,
    "default",
    FromJson<TaskType>("{\"Id\":86,\"SystemName\":\"IntegrationHealthCheckQueuedOrRunning\",\"Name\":\"Uzun süredir işlemde kalan görevlerin bildirimi\",\"JobClassName\":\"IntegrationHealthCheckQueuedOrRunningTask\",\"Type\":\"Recurring\",\"Cron\":\"*/10 * * * *\",\"AccountId\":1,\"SalesChannelOption\":1,\"AccountOption\":1,\"SalesChannelOptionEnum\":1,\"AccountOptionEnum\":1,\"CreatedOnUtc\":\"2025-01-17T11:19:00\",\"UpdatedOnUtc\":\"2025-01-17T11:19:00\",\"IsActive\":true,\"TaskTypeSalesChannel\":[{\"Id\":182,\"TaskTypeId\":86,\"SalesChannelId\":2,\"CreatedOnUtc\":\"2025-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2025-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":183,\"TaskTypeId\":86,\"SalesChannelId\":3,\"CreatedOnUtc\":\"2025-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2025-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":187,\"TaskTypeId\":86,\"SalesChannelId\":1,\"CreatedOnUtc\":\"2025-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2025-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":191,\"TaskTypeId\":86,\"SalesChannelId\":7,\"CreatedOnUtc\":\"2025-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2025-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":192,\"TaskTypeId\":86,\"SalesChannelId\":9,\"CreatedOnUtc\":\"2025-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2025-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":193,\"TaskTypeId\":86,\"SalesChannelId\":14,\"CreatedOnUtc\":\"2025-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2025-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":194,\"TaskTypeId\":86,\"SalesChannelId\":15,\"CreatedOnUtc\":\"2025-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2025-05-22T15:26:29.407\",\"IsActive\":true}]}"));

Parameters

CurrentCulture
""
CurrentUICulture
""
RecurringJobId
"IntegrationHealthCheckQueuedOrRunning"
Time
1763344814

State

11/17/2025 02:01:47 (+1m 32.811s) Failed

An exception occurred during performance of the job.

System.InvalidOperationException

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): 57P03: the database system is shutting down
   at Npgsql.Internal.NpgsqlConnector.<ReadMessage>g__ReadMessageLong|215_0(NpgsqlConnector connector, Boolean async, DataRowLoadingMode dataRowLoadingMode, Boolean readingNotifications, Boolean isReadingPrependedMessage)
   at Npgsql.Internal.NpgsqlConnector.Authenticate(String username, NpgsqlTimeout timeout, Boolean async, CancellationToken cancellationToken)
   at Npgsql.Internal.NpgsqlConnector.<Open>g__OpenCore|195_1(NpgsqlConnector conn, SslMode sslMode, NpgsqlTimeout timeout, Boolean async, CancellationToken cancellationToken, Boolean isFirstAttempt)
   at Npgsql.Internal.NpgsqlConnector.Open(NpgsqlTimeout timeout, Boolean async, CancellationToken cancellationToken)
   at Npgsql.ConnectorPool.OpenNewConnector(NpgsqlConnection conn, NpgsqlTimeout timeout, Boolean async, CancellationToken cancellationToken)
   at Npgsql.ConnectorPool.<Get>g__RentAsync|28_0(NpgsqlConnection conn, NpgsqlTimeout timeout, Boolean async, CancellationToken cancellationToken)
   at Npgsql.NpgsqlConnection.<Open>g__OpenAsync|45_0(Boolean async, CancellationToken cancellationToken)
   at Microsoft.EntityFrameworkCore.Storage.RelationalConnection.OpenInternalAsync(Boolean errorsExpected, CancellationToken cancellationToken)
   at Microsoft.EntityFrameworkCore.Storage.RelationalConnection.OpenInternalAsync(Boolean errorsExpected, CancellationToken cancellationToken)
   at Microsoft.EntityFrameworkCore.Storage.RelationalConnection.OpenAsync(CancellationToken cancellationToken, Boolean errorsExpected)
   at Microsoft.EntityFrameworkCore.Storage.RelationalConnection.BeginTransactionAsync(IsolationLevel isolationLevel, CancellationToken cancellationToken)
   at Microsoft.EntityFrameworkCore.Storage.RelationalConnection.BeginTransactionAsync(CancellationToken cancellationToken)
   at Microsoft.EntityFrameworkCore.Update.Internal.BatchExecutor.ExecuteAsync(IEnumerable`1 commandBatches, IRelationalConnection connection, CancellationToken cancellationToken)
   at Microsoft.EntityFrameworkCore.Update.Internal.BatchExecutor.ExecuteAsync(IEnumerable`1 commandBatches, IRelationalConnection connection, CancellationToken cancellationToken)
   at Microsoft.EntityFrameworkCore.Update.Internal.BatchExecutor.ExecuteAsync(IEnumerable`1 commandBatches, IRelationalConnection connection, CancellationToken cancellationToken)
   at Microsoft.EntityFrameworkCore.ChangeTracking.Internal.StateManager.SaveChangesAsync(IList`1 entriesToSave, CancellationToken cancellationToken)
   at Microsoft.EntityFrameworkCore.ChangeTracking.Internal.StateManager.SaveChangesAsync(StateManager stateManager, Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken)
   at Npgsql.EntityFrameworkCore.PostgreSQL.Storage.Internal.NpgsqlExecutionStrategy.ExecuteAsync[TState,TResult](TState state, Func`4 operation, Func`4 verifySucceeded, CancellationToken cancellationToken)
  Exception data:
    Severity: FATAL
    SqlState: 57P03
    MessageText: the database system is shutting down
    File: postmaster.c
    Line: 2381
    Routine: ProcessStartupPacket
   --- End of inner exception stack trace ---
   at Npgsql.EntityFrameworkCore.PostgreSQL.Storage.Internal.NpgsqlExecutionStrategy.ExecuteAsync[TState,TResult](TState state, Func`4 operation, Func`4 verifySucceeded, CancellationToken cancellationToken)
   at Microsoft.EntityFrameworkCore.DbContext.SaveChangesAsync(Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken)
   at Microsoft.EntityFrameworkCore.DbContext.SaveChangesAsync(Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken)
   at EkolPY.Integration.Service.IntegrationTaskService.AddTaskLog(TaskLogLevel logLevel, String[] messages) in /src/Integration/EkolPY.Integration.Service/IntegrationService.cs:line 163
   at EkolPY.Integration.Service.IntegrationTaskService.AddTaskError(Exception ex, String[] msgs) in /src/Integration/EkolPY.Integration.Service/IntegrationService.cs:line 151
   at EkolPY.Integration.Service.IntegrationTaskService.SetFailedWithException(String message, Exception ex) in /src/Integration/EkolPY.Integration.Service/IntegrationService.cs:line 264
   at EkolPY.Integration.Manager.TaskBase`1.ProcessRecurringAsync(PerformContext context, String queueName, TaskType taskType) in /src/Integration/EkolPY.Integration.Manager/TaskBase.cs:line 162
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)

+10ms Processing

Server:
ekol-py-int-prod-986d4b575-njq5g:1
Worker:
0792cd6e

+4ms Enqueued

Triggered by recurring job scheduler

Queue:
default

11/17/2025 02:00:14 Created