Skip to content
This repository was archived by the owner on Nov 1, 2023. It is now read-only.
Merged
Prev Previous commit
Next Next commit
cleanup
  • Loading branch information
tevoinea committed Oct 18, 2023
commit e65b9f7ad9d799f9e37f5ffe864ec4f7f12f7345
6 changes: 5 additions & 1 deletion src/ApiService/ApiService/Functions/QueueFileChanges.cs
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,11 @@ public async Async.Task Run(
try {
var result = await FileAdded(storageAccount, fileChangeEvent);
if (!result.IsOk) {
await RequeueMessage(msg, result.ErrorV.Code == ErrorCode.ADO_WORKITEM_PROCESSING_DISABLED ? TimeSpan.FromDays(1) : null);
if (result.ErrorV.Code == ErrorCode.ADO_WORKITEM_PROCESSING_DISABLED) {
await RequeueMessage(msg, TimeSpan.FromDays(1), incrementDequeueCount: false);
} else {
await RequeueMessage(msg);
}
}
} catch (Exception e) {
_log.LogError(e, "File Added failed");
Expand Down
1 change: 0 additions & 1 deletion src/ApiService/ApiService/onefuzzlib/Containers.cs
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,6 @@ public interface IContainers {
public Async.Task DeleteAllExpiredBlobs();

public Async.Task<OneFuzzResultVoid> CreateOrUpdateContainerTag(Container container, StorageType storageType, Dictionary<string, string> tags);
// TODO: Create a utils class for the skip notifications tag
}

public class Containers : Orm<ContainerInformation>, IContainers {
Expand Down