RetrieveProductReleaseBatchResultsTask.ProcessRecurringAsync

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

var retrieveProductReleaseBatchResultsTask = Activate<RetrieveProductReleaseBatchResultsTask>();
await retrieveProductReleaseBatchResultsTask.ProcessRecurringAsync(
    null,
    "default",
    FromJson<TaskType>("{\"Id\":50,\"SystemName\":\"RetrieveProductReleaseBatchResults\",\"Name\":\"Ürün yayınlama işlem sonuçları çekimi\",\"JobClassName\":\"RetrieveProductReleaseBatchResultsTask\",\"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\":7,\"TaskTypeId\":50,\"SalesChannelId\":2,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":15,\"TaskTypeId\":50,\"SalesChannelId\":14,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":28,\"TaskTypeId\":50,\"SalesChannelId\":3,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":93,\"TaskTypeId\":50,\"SalesChannelId\":7,\"CreatedOnUtc\":\"2023-10-17T00:00:00\",\"UpdatedOnUtc\":null,\"IsActive\":true},{\"Id\":156,\"TaskTypeId\":50,\"SalesChannelId\":1,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true}]}"));

Parameters

CurrentCulture
""
CurrentUICulture
""
RecurringJobId
"RetrieveProductReleaseBatchResults"
Time
1757344567

State

09/08/2025 15:17:17 (+48.796s) 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)

+21.030s Processing

Server:
ekol-py-int-prod-555975dbc5-75977:1
Worker:
912cdf09

+4ms Enqueued

Triggered by recurring job scheduler

Queue:
default

09/08/2025 15:16:07 Created