Obase - Ekol PY

RetrieveProductStatusTask.ProcessRecurringAsync

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

var retrieveProductStatusTask = Activate<RetrieveProductStatusTask>();
await retrieveProductStatusTask.ProcessRecurringAsync(
    null,
    "default",
    FromJson<TaskType>("{\"Id\":23,\"SystemName\":\"RetrieveProductStatus\",\"Name\":\"Ürün Durumlarının Çekimi\",\"JobClassName\":\"RetrieveProductStatusTask\",\"Type\":\"Recurring\",\"Cron\":\"*/15 * * * *\",\"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\":6,\"TaskTypeId\":23,\"SalesChannelId\":2,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":14,\"TaskTypeId\":23,\"SalesChannelId\":14,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":29,\"TaskTypeId\":23,\"SalesChannelId\":3,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":91,\"TaskTypeId\":23,\"SalesChannelId\":7,\"CreatedOnUtc\":\"2023-10-17T00:00:00\",\"UpdatedOnUtc\":null,\"IsActive\":true},{\"Id\":39,\"TaskTypeId\":23,\"SalesChannelId\":1,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true},{\"Id\":170,\"TaskTypeId\":23,\"SalesChannelId\":15,\"CreatedOnUtc\":\"2023-05-22T15:26:29.407\",\"UpdatedOnUtc\":\"2023-05-22T15:26:29.407\",\"IsActive\":true}]}"));

Parameters

CurrentCulture 
""
CurrentUICulture 
""
RecurringJobId 
"RetrieveProductStatus"
Time 
1752183905

State

07/10/2025 22:40:35 (+55m 29.841s) Failed

An exception occurred during performance of the job.

Grpc.Core.RpcException

Status(StatusCode="InvalidArgument", Detail="Property array contains an invalid nested entity.")

Grpc.Core.RpcException: Status(StatusCode="InvalidArgument", Detail="Property array contains an invalid nested entity.")
   at Google.Api.Gax.Grpc.ApiCallRetryExtensions.<>c__DisplayClass0_0`2.<<WithRetry>b__0>d.MoveNext()
--- End of stack trace from previous location ---
   at Google.Cloud.Firestore.WriteBatch.CommitAsync(ByteString transactionId, CancellationToken cancellationToken)
   at Google.Cloud.Firestore.DocumentReference.SetAsync(Object documentData, SetOptions options, CancellationToken cancellationToken)
   at EkolPY.Integration.Data.FireStore.FireStoreRepository`1.UpdateItemAsync(String id, TEntity item) in /src/Integration/EkolPY.Integration.Data.FireStore/Repository/FirestoreRepository.cs:line 78
   at EkolPY.Integration.Service.IntegrationTaskService.SaveLog() in /src/Integration/EkolPY.Integration.Service/IntegrationService.cs:line 441
   at EkolPY.Integration.Service.IntegrationTaskService.SetFailedAsync() in /src/Integration/EkolPY.Integration.Service/IntegrationService.cs:line 482
   at EkolPY.Integration.Service.IntegrationTaskService.SetFailedWithException(String message, Exception ex) in /src/Integration/EkolPY.Integration.Service/IntegrationService.cs:line 496
   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)

+17ms Processing

Server:
ekol-py-int-prod-7d8c999c44-kvj4x:1
Worker:
ad37745d

+5ms Enqueued

Triggered by recurring job scheduler

Queue:
default

07/10/2025 21:45:05 Created