IWindAndSolarGenerationSyncJob.Run

Npgsql.NpgsqlException (edh:2561946)

Exception while reading from stream

Npgsql.NpgsqlException: Exception while reading from stream ---> System.IO.EndOfStreamException: Attempted to read past the end of the stream.
   at Npgsql.Internal.NpgsqlReadBuffer.<Ensure>g__EnsureLong|55_0(NpgsqlReadBuffer buffer, Int32 count, Boolean async, Boolean readingNotifications)

   --- End of inner exception stack trace ---
   at Npgsql.Internal.NpgsqlReadBuffer.<Ensure>g__EnsureLong|55_0(NpgsqlReadBuffer buffer, Int32 count, Boolean async, Boolean readingNotifications)
   at System.Runtime.CompilerServices.PoolingAsyncValueTaskMethodBuilder`1.StateMachineBox`1.System.Threading.Tasks.Sources.IValueTaskSource.GetResult(Int16 token)
   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.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.NpgsqlBinaryImporter.Init(String copyFromCommand, Boolean async, CancellationToken cancellationToken)
   at Npgsql.NpgsqlConnection.BeginBinaryImport(Boolean async, String copyFromCommand, CancellationToken cancellationToken)
   at EnergyDataHub.Data.Services.TimeseriesBulkInserter.BulkInsertAsync(IEnumerable`1 values)
   at EnergyDataHub.Data.Services.TimeseriesBulkInserter.BulkInsertAsync(IEnumerable`1 values)
   at EnergyDataHub.Data.Helpers.TimeseriesBatchCollector.<>c__DisplayClass1_0.<<CreateInsertAction>b__0>d.MoveNext()
--- End of stack trace from previous location ---
   at EnergyDataHub.Data.Helpers.BatchCollector`1.AddAsync(T item)
   at EnergyDataHub.Data.Services.TimeseriesUpdateService.UpdateTimeseriesAsync[TData](Int64 timeseriesId, List`1 data, Nullable`1 startDateToDelete, Nullable`1 endDateToDelete, DataSource dataSource, AppDbContext context)
   at EnergyDataHub.Data.Services.WindAndSolarGenerationService.UpdateGeneration(WindAndSolarGenerations windAndSolarGeneration, List`1 windAndSolarGenerationData, AppDbContext context, DataSource dataSource)
   at EnergyDataHub.Data.Services.WindAndSolarGenerationService.UpdateGeneration(Country country, List`1 windAndSolarGenerationData, AppDbContext context, DataSource dataSource)
   at EnergyDataHub.Data.Services.CountryService.MapWindAndSolarGeneration(List`1 data, AppDbContext context, DataSource dataSource)
   at EnergyDataHub.Data.Services.DataFetchService.MapAndFetchData[TParser,TData](DocumentType documentType, AreaEnum area, Dictionary`2 baseParameters, Func`4 dataMethod)
   at EnergyDataHub.Data.Services.DataFetchService.MapAndFetchData[TParser,TData](DocumentType documentType, AreaEnum area, Dictionary`2 baseParameters, Func`4 dataMethod)
   at EnergyDataHub.Data.Helpers.ConcurrencyHelper.ProcessTasksInBatchesAsync(IEnumerable`1 taskFuncs, Int32 batchSize)
   at EnergyDataHub.Data.Hangfire.Jobs.WindAndSolarGenerationSyncJob.Run()
   at InvokeStub_TaskAwaiter.GetResult(Object, Object, IntPtr*)
   at System.Reflection.MethodBaseInvoker.InvokeWithNoArgs(Object obj, BindingFlags invokeAttr)