diff --git a/src/NCronJob/Scheduler/QueueWorker.LogMessage.cs b/src/NCronJob/Scheduler/QueueWorker.LogMessage.cs index a6c52ba..5238b26 100644 --- a/src/NCronJob/Scheduler/QueueWorker.LogMessage.cs +++ b/src/NCronJob/Scheduler/QueueWorker.LogMessage.cs @@ -35,8 +35,8 @@ internal sealed partial class QueueWorker private partial void LogCancellationRequestedInJob(); [LoggerMessage(LogLevel.Information, "Job added to queue: {JobType} at {RunAt:o}")] - private partial void LogJobAddedToQueue(string jobType, DateTime? runAt); + private partial void LogJobAddedToQueue(string jobType, DateTimeOffset? runAt); [LoggerMessage(LogLevel.Information, "Job removed from queue: {JobType} at {RunAt:o}")] - private partial void LogJobRemovedFromQueue(string jobType, DateTime? runAt); + private partial void LogJobRemovedFromQueue(string jobType, DateTimeOffset? runAt); } diff --git a/src/NCronJob/Scheduler/QueueWorker.cs b/src/NCronJob/Scheduler/QueueWorker.cs index 21aeade..353b80d 100644 --- a/src/NCronJob/Scheduler/QueueWorker.cs +++ b/src/NCronJob/Scheduler/QueueWorker.cs @@ -195,13 +195,13 @@ private void HandleUpdate(object? sender, NotifyCollectionChangedEventArgs e) case NotifyCollectionChangedAction.Add: foreach (JobRun job in e.NewItems!) { - LogJobAddedToQueue(job.JobDefinition.Type.Name, job.RunAt?.LocalDateTime); + LogJobAddedToQueue(job.JobDefinition.Type.Name, job.RunAt); } break; case NotifyCollectionChangedAction.Remove: foreach (JobRun job in e.OldItems!) { - LogJobRemovedFromQueue(job.JobDefinition.Type.Name, job.RunAt?.LocalDateTime); + LogJobRemovedFromQueue(job.JobDefinition.Type.Name, job.RunAt); } break; case NotifyCollectionChangedAction.Replace: