Skip to content

Commit 22fef61

Browse files
committed
PR feedback
1 parent 15273ad commit 22fef61

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

src/Foundatio/Jobs/QueueJobBase.cs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -121,8 +121,6 @@ public async Task<JobResult> ProcessAsync(IQueueEntry<T> queueEntry, Cancellatio
121121
}
122122
else
123123
{
124-
activity?.SetErrorStatus(result.Error, result.Message ?? result.Error?.Message);
125-
126124
if (result.Error != null || result.Message != null)
127125
_logger.LogError(result.Error, "{QueueName} queue entry {QueueEntryId} returned an unsuccessful response: {Message}", _queueName, queueEntry.Id, result.Message ?? result.Error?.Message);
128126

src/Foundatio/Queues/SharedQueueOptions.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,8 @@ public TBuilder AddBehavior(IQueueBehavior<T> behavior)
6565
{
6666
ArgumentNullException.ThrowIfNull(behavior);
6767

68-
Target.Behaviors ??= new List<IQueueBehavior<T>>();
68+
if (Target.Behaviors == null)
69+
Target.Behaviors = new List<IQueueBehavior<T>>();
6970
Target.Behaviors.Add(behavior);
7071

7172
return (TBuilder)this;

0 commit comments

Comments
 (0)