IGenerationSyncJob.Run

// Id: #4014
using EnergyDataHub.Data.Hangfire.Jobs;

var generationSyncJob = Activate<IGenerationSyncJob>();
await generationSyncJob.Run();

Parameters

RecurringJobId
"IGenerationSyncJob"
Time
1747135808
CurrentCulture
""
CurrentUICulture
""

State

05/13/2025 13:28:09 (+1h 58m) Failed

An exception occurred during performance of the job.

Npgsql.NpgsqlException (edh:2770111)

Exception while writing to stream

Npgsql.NpgsqlException: Exception while writing to stream ---> System.TimeoutException: Timeout during writing attempt
   --- End of inner exception stack trace ---
   at Npgsql.Internal.NpgsqlWriteBuffer.Flush(Boolean async, CancellationToken cancellationToken)
   at Npgsql.Internal.NpgsqlBufferWriter.Flush(TimeSpan timeout)
   at Npgsql.Internal.PgWriter.Flush(Boolean async, CancellationToken cancellationToken)
   at Npgsql.NpgsqlParameter.Write(Boolean async, PgWriter writer, CancellationToken cancellationToken)
   at Npgsql.NpgsqlBinaryImporter.<Write>g__Core|26_0[T](Boolean async, T value, Nullable`1 npgsqlDbType, String dataTypeName, CancellationToken cancellationToken)
   at EnergyDataHub.Data.Services.TimeseriesBulkInserter.BulkInsertAsync(IEnumerable`1 values)
   at EnergyDataHub.Data.Services.TimeseriesBulkInserter.BulkInsertAsync(IEnumerable`1 values)
   at EnergyDataHub.Data.Services.TimeseriesBulkInserter.BulkInsertAsync(IEnumerable`1 values)
   at EnergyDataHub.Data.Services.GenerationService.UpdateOutputAndConsumption(List`1 generationIds, List`1 data, AppDbContext context, DataSource dataSource)
   at EnergyDataHub.Data.Services.BiddingZoneService.MapActualGeneration(List`1 data, AppDbContext context, DataSource dataSource)
   at EnergyDataHub.Data.Services.SftpService.MapDataToEachArea[DataClass,CsvMapper](String remoteDirectory, List`1 dataMethods, Int32 retryCount)
   at EnergyDataHub.Data.Services.SftpService.MapDataToEachArea[DataClass,CsvMapper](String remoteDirectory, List`1 dataMethods)
   at EnergyDataHub.Data.Hangfire.Jobs.GenerationSyncJob.Run()
   at InvokeStub_TaskAwaiter.GetResult(Object, Object, IntPtr*)
   at System.Reflection.MethodBaseInvoker.InvokeWithNoArgs(Object obj, BindingFlags invokeAttr)

+23ms Processing

Server:
edh:2770111
Worker:
cecf4b1a

+10ms Enqueued

Triggered by recurring job scheduler

05/13/2025 11:30:08 Created