RetrieveUpdateProductStockBatchResultsTask.ProcessRecurringAsync

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

var retrieveUpdateProductStockBatchResultsTask = Activate<RetrieveUpdateProductStockBatchResultsTask>();
await retrieveUpdateProductStockBatchResultsTask.ProcessRecurringAsync(
    null,
    "default",
    FromJson<TaskType>("{\"Id\":54,\"SystemName\":\"RetrieveUpdateProductStockBatchResults\",\"Name\":\"Stok güncelleme işlem sonuçları çekimi\",\"JobClassName\":\"RetrieveUpdateProductStockBatchResultsTask\",\"Type\":\"Recurring\",\"Cron\":\"*/2 * * * *\",\"AccountId\":1,\"SalesChannelOption\":1,\"AccountOption\":1,\"SalesChannelOptionEnum\":1,\"AccountOptionEnum\":1,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true,\"TaskTypeSalesChannel\":[{\"Id\":19,\"TaskTypeId\":54,\"SalesChannelId\":2,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":20,\"TaskTypeId\":54,\"SalesChannelId\":14,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":21,\"TaskTypeId\":54,\"SalesChannelId\":3,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":127,\"TaskTypeId\":54,\"SalesChannelId\":7,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":113,\"TaskTypeId\":54,\"SalesChannelId\":1,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true}]}"));

Parameters

CurrentCulture
""
CurrentUICulture
""
RecurringJobId
"RetrieveUpdateProductStockBatchResults"
Time
1757120643

State

09/06/2025 01:05:36 (+1m 33.259s) Failed

An exception occurred during processing of a background job.

Npgsql.NpgsqlOperationInProgressException

The connection is already in state 'Executing'

Npgsql.NpgsqlOperationInProgressException (0x80004005): The connection is already in state 'Executing'
   at Npgsql.Internal.NpgsqlConnector.<StartUserAction>g__DoStartUserAction|259_0(<>c__DisplayClass259_0& )
   at Npgsql.Internal.NpgsqlConnector.StartUserAction(ConnectorState newState, NpgsqlCommand command, CancellationToken cancellationToken, Boolean attemptPgCancellation)
   at Npgsql.Internal.NpgsqlConnector.Reset(Boolean async)
   at Npgsql.NpgsqlConnection.CloseAsync(Boolean async)
   at Npgsql.NpgsqlConnection.Close()
   at Microsoft.EntityFrameworkCore.Storage.RelationalConnection.Close()
   at Microsoft.EntityFrameworkCore.Storage.RelationalTransaction.ClearTransaction()
   at Microsoft.EntityFrameworkCore.Storage.RelationalTransaction.Dispose()
   at Microsoft.EntityFrameworkCore.Storage.RelationalConnection.ResetState(Boolean disposeDbConnection)
   at Microsoft.Extensions.DependencyInjection.ServiceLookup.ServiceProviderEngineScope.Dispose()
   at Microsoft.EntityFrameworkCore.DbContext.Dispose()
   at Microsoft.Extensions.DependencyInjection.ServiceLookup.ServiceProviderEngineScope.Dispose()
   at Hangfire.JobActivatorScope.Dispose()
   at Hangfire.Server.CoreBackgroundJobPerformer.Perform(PerformContext context)
   at Hangfire.Server.BackgroundJobPerformer.<>c__DisplayClass9_0.<PerformJobWithFilters>b__0()
   at Hangfire.Server.BackgroundJobPerformer.InvokePerformFilter(IServerFilter filter, PerformingContext preContext, Func`1 continuation)
   at Hangfire.Server.BackgroundJobPerformer.PerformJobWithFilters(PerformContext context, IEnumerable`1 filters)
   at Hangfire.Server.BackgroundJobPerformer.Perform(PerformContext context)
   at Hangfire.Server.Worker.PerformJob(BackgroundProcessContext context, IStorageConnection connection, String jobId)

+12ms Processing

Server:
ekol-py-int-prod-555975dbc5-75977:1
Worker:
28f22d58

+4ms Enqueued

Triggered by recurring job scheduler

Queue:
default

09/06/2025 01:04:03 Created