// Id: #2518003
// Queue: jetti-test_jetti-neto-low
using Aurus.Jetti.Integrations.Neto;
var netoInventorySyncJob = Activate<NetoInventorySyncJob>();
await netoInventorySyncJob.ExecuteAsync(
FromJson<NetoInventorySyncJobArgs>("{\"JobType\":2}"));
| CurrentCulture | |
| RetryCount | |
Retry attempt 4 of 10: Neto API error. Action=GetItem, Status=503, Body=
An exception occurred during performance of the job.
Neto API error. Action=GetItem, Status=503, Body=
System.InvalidOperationException: Neto API error. Action=GetItem, Status=503, Body= ---> System.Net.Http.HttpRequestException: Response status code does not indicate success: 503 (Service Unavailable). at System.Net.Http.HttpResponseMessage.EnsureSuccessStatusCode() at Aurus.Jetti.Integrations.Neto.HttpClients.NetoHttpClientBase.PostAsync[T](String netoAction, Object requestBody) in /src/src/integrations/Neto/Aurus.Jetti.Integrations.Neto/HttpClients/NetoHttpClientBase.cs:line 114 --- End of inner exception stack trace --- at Aurus.Jetti.Integrations.Neto.HttpClients.NetoHttpClientBase.PostAsync[T](String netoAction, Object requestBody) in /src/src/integrations/Neto/Aurus.Jetti.Integrations.Neto/HttpClients/NetoHttpClientBase.cs:line 139 at Aurus.Jetti.Integrations.Neto.HttpClients.Products.ProductsHttpClient.GetItemsAsync(GetItemRequest request) in /src/src/integrations/Neto/Aurus.Jetti.Integrations.Neto/HttpClients/Products/ProductsHttpClient.cs:line 82 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.FetchItemsByInventoryIdsAsync(IReadOnlyCollection`1 candidates, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 906 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.FetchSweepReconciliationItemsAsync(String cursorRaw, Int32 batchSize, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 831 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.FetchReconciliationItemsAsync(NetoInventorySyncJobType jobType, String cursorRaw, Int32 batchSize, DateTime nowUtc, SyncScheduleOptions schedule, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 765 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.ExecuteAsync(NetoInventorySyncRequest request, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 158 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.ExecuteAsync(NetoInventorySyncRequest request, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 262 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncJob.ExecuteAsync(NetoInventorySyncJobArgs args) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncJob.cs:line 40 at Castle.DynamicProxy.AsyncInterceptorBase.ProceedAsynchronous(IInvocation invocation, IInvocationProceedInfo proceedInfo) at Volo.Abp.Castle.DynamicProxy.CastleAbpMethodInvocationAdapter.ProceedAsync() at Volo.Abp.Uow.UnitOfWorkInterceptor.InterceptAsync(IAbpMethodInvocation invocation) at Volo.Abp.Castle.DynamicProxy.CastleAsyncAbpInterceptorAdapter`1.InterceptAsync(IInvocation invocation, IInvocationProceedInfo proceedInfo, Func`3 proceed) at InvokeStub_TaskAwaiter.GetResult(Object, Object, IntPtr*) at System.Reflection.MethodBaseInvoker.InvokeWithNoArgs(Object obj, BindingFlags invokeAttr)
Retry attempt 3 of 10: Neto API error. Action=GetItem, Status=503, Body=
An exception occurred during performance of the job.
Neto API error. Action=GetItem, Status=503, Body=
System.InvalidOperationException: Neto API error. Action=GetItem, Status=503, Body= ---> System.Net.Http.HttpRequestException: Response status code does not indicate success: 503 (Service Unavailable). at System.Net.Http.HttpResponseMessage.EnsureSuccessStatusCode() at Aurus.Jetti.Integrations.Neto.HttpClients.NetoHttpClientBase.PostAsync[T](String netoAction, Object requestBody) in /src/src/integrations/Neto/Aurus.Jetti.Integrations.Neto/HttpClients/NetoHttpClientBase.cs:line 114 --- End of inner exception stack trace --- at Aurus.Jetti.Integrations.Neto.HttpClients.NetoHttpClientBase.PostAsync[T](String netoAction, Object requestBody) in /src/src/integrations/Neto/Aurus.Jetti.Integrations.Neto/HttpClients/NetoHttpClientBase.cs:line 139 at Aurus.Jetti.Integrations.Neto.HttpClients.Products.ProductsHttpClient.GetItemsAsync(GetItemRequest request) in /src/src/integrations/Neto/Aurus.Jetti.Integrations.Neto/HttpClients/Products/ProductsHttpClient.cs:line 82 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.FetchItemsByInventoryIdsAsync(IReadOnlyCollection`1 candidates, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 906 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.FetchSweepReconciliationItemsAsync(String cursorRaw, Int32 batchSize, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 831 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.FetchReconciliationItemsAsync(NetoInventorySyncJobType jobType, String cursorRaw, Int32 batchSize, DateTime nowUtc, SyncScheduleOptions schedule, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 765 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.ExecuteAsync(NetoInventorySyncRequest request, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 158 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.ExecuteAsync(NetoInventorySyncRequest request, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 262 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncJob.ExecuteAsync(NetoInventorySyncJobArgs args) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncJob.cs:line 40 at Castle.DynamicProxy.AsyncInterceptorBase.ProceedAsynchronous(IInvocation invocation, IInvocationProceedInfo proceedInfo) at Volo.Abp.Castle.DynamicProxy.CastleAbpMethodInvocationAdapter.ProceedAsync() at Volo.Abp.Uow.UnitOfWorkInterceptor.InterceptAsync(IAbpMethodInvocation invocation) at Volo.Abp.Castle.DynamicProxy.CastleAsyncAbpInterceptorAdapter`1.InterceptAsync(IInvocation invocation, IInvocationProceedInfo proceedInfo, Func`3 proceed) at InvokeStub_TaskAwaiter.GetResult(Object, Object, IntPtr*) at System.Reflection.MethodBaseInvoker.InvokeWithNoArgs(Object obj, BindingFlags invokeAttr)
Retry attempt 2 of 10: An exception has been raised that is likely due t…
An exception occurred during performance of the job.
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. ---> Microsoft.EntityFrameworkCore.DbUpdateException: An error occurred while saving the entity changes. See the inner exception for details. ---> Npgsql.PostgresException: 40P01: deadlock detected DETAIL: Detail redacted as it may contain sensitive data. Specify 'Include Error Detail' in the connection string to include this information. 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.NpgsqlDataReader.NextResult(Boolean async, Boolean isConsuming, CancellationToken cancellationToken) at Npgsql.NpgsqlDataReader.NextResult(Boolean async, Boolean isConsuming, CancellationToken cancellationToken) at Npgsql.NpgsqlCommand.ExecuteReader(Boolean async, CommandBehavior behavior, CancellationToken cancellationToken) at Npgsql.NpgsqlCommand.ExecuteReader(Boolean async, CommandBehavior behavior, CancellationToken cancellationToken) at Npgsql.NpgsqlCommand.ExecuteDbDataReaderAsync(CommandBehavior behavior, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.Storage.RelationalCommand.ExecuteReaderAsync(RelationalCommandParameterObject parameterObject, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.Storage.RelationalCommand.ExecuteReaderAsync(RelationalCommandParameterObject parameterObject, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.Update.ReaderModificationCommandBatch.ExecuteAsync(IRelationalConnection connection, CancellationToken cancellationToken) --- End of inner exception stack trace --- at Microsoft.EntityFrameworkCore.Update.ReaderModificationCommandBatch.ExecuteAsync(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.Update.Internal.BatchExecutor.ExecuteAsync(IEnumerable`1 commandBatches, IRelationalConnection connection, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.Storage.RelationalDatabase.SaveChangesAsync(IList`1 entries, 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) --- 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 Volo.Abp.EntityFrameworkCore.AbpDbContext`1.SaveChangesAsync(Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken) at Volo.Abp.Domain.Repositories.EntityFrameworkCore.EfCoreRepository`2.UpdateManyAsync(IEnumerable`1 entities, Boolean autoSave, CancellationToken cancellationToken) at Castle.DynamicProxy.AsyncInterceptorBase.ProceedAsynchronous(IInvocation invocation, IInvocationProceedInfo proceedInfo) at Volo.Abp.Castle.DynamicProxy.CastleAbpMethodInvocationAdapter.ProceedAsync() at Volo.Abp.Uow.UnitOfWorkInterceptor.InterceptAsync(IAbpMethodInvocation invocation) at Volo.Abp.Castle.DynamicProxy.CastleAsyncAbpInterceptorAdapter`1.InterceptAsync(IInvocation invocation, IInvocationProceedInfo proceedInfo, Func`3 proceed) at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.SaveProductUpdatesInChunksAsync(IReadOnlyCollection`1 updates, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 936 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.ApplyFetchedItemsAsync(IReadOnlyCollection`1 items, NetoInventorySyncResult result, String runId, Boolean touchMatchedProducts, Boolean syncExternalChannels, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 652 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.ExecuteAsync(NetoInventorySyncRequest request, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 186 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.ExecuteAsync(NetoInventorySyncRequest request, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 262 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncJob.ExecuteAsync(NetoInventorySyncJobArgs args) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncJob.cs:line 40 at Castle.DynamicProxy.AsyncInterceptorBase.ProceedAsynchronous(IInvocation invocation, IInvocationProceedInfo proceedInfo) at Volo.Abp.Castle.DynamicProxy.CastleAbpMethodInvocationAdapter.ProceedAsync() at Volo.Abp.Uow.UnitOfWorkInterceptor.InterceptAsync(IAbpMethodInvocation invocation) at Volo.Abp.Castle.DynamicProxy.CastleAsyncAbpInterceptorAdapter`1.InterceptAsync(IInvocation invocation, IInvocationProceedInfo proceedInfo, Func`3 proceed) at InvokeStub_TaskAwaiter.GetResult(Object, Object, IntPtr*) at System.Reflection.MethodBaseInvoker.InvokeWithNoArgs(Object obj, BindingFlags invokeAttr)
Retry attempt 1 of 10: Neto API error. Action=GetItem, Status=503, Body=
An exception occurred during performance of the job.
Neto API error. Action=GetItem, Status=503, Body=
System.InvalidOperationException: Neto API error. Action=GetItem, Status=503, Body= ---> System.Net.Http.HttpRequestException: Response status code does not indicate success: 503 (Service Unavailable). at System.Net.Http.HttpResponseMessage.EnsureSuccessStatusCode() at Aurus.Jetti.Integrations.Neto.HttpClients.NetoHttpClientBase.PostAsync[T](String netoAction, Object requestBody) in /src/src/integrations/Neto/Aurus.Jetti.Integrations.Neto/HttpClients/NetoHttpClientBase.cs:line 114 --- End of inner exception stack trace --- at Aurus.Jetti.Integrations.Neto.HttpClients.NetoHttpClientBase.PostAsync[T](String netoAction, Object requestBody) in /src/src/integrations/Neto/Aurus.Jetti.Integrations.Neto/HttpClients/NetoHttpClientBase.cs:line 139 at Aurus.Jetti.Integrations.Neto.HttpClients.Products.ProductsHttpClient.GetItemsAsync(GetItemRequest request) in /src/src/integrations/Neto/Aurus.Jetti.Integrations.Neto/HttpClients/Products/ProductsHttpClient.cs:line 82 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.FetchItemsByInventoryIdsAsync(IReadOnlyCollection`1 candidates, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 906 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.FetchSweepReconciliationItemsAsync(String cursorRaw, Int32 batchSize, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 831 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.FetchReconciliationItemsAsync(NetoInventorySyncJobType jobType, String cursorRaw, Int32 batchSize, DateTime nowUtc, SyncScheduleOptions schedule, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 765 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.ExecuteAsync(NetoInventorySyncRequest request, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 158 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncService.ExecuteAsync(NetoInventorySyncRequest request, CancellationToken cancellationToken) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncService.cs:line 262 at Aurus.Jetti.Integrations.Neto.NetoInventorySyncJob.ExecuteAsync(NetoInventorySyncJobArgs args) in /src/src/Aurus.Jetti.Application/Integrations/Neto/NetoInventorySyncJob.cs:line 40 at Castle.DynamicProxy.AsyncInterceptorBase.ProceedAsynchronous(IInvocation invocation, IInvocationProceedInfo proceedInfo) at Volo.Abp.Castle.DynamicProxy.CastleAbpMethodInvocationAdapter.ProceedAsync() at Volo.Abp.Uow.UnitOfWorkInterceptor.InterceptAsync(IAbpMethodInvocation invocation) at Volo.Abp.Castle.DynamicProxy.CastleAsyncAbpInterceptorAdapter`1.InterceptAsync(IInvocation invocation, IInvocationProceedInfo proceedInfo, Func`3 proceed) at InvokeStub_TaskAwaiter.GetResult(Object, Object, IntPtr*) at System.Reflection.MethodBaseInvoker.InvokeWithNoArgs(Object obj, BindingFlags invokeAttr)