diff --git a/Expedience.Api/Consumers/DutyCompletionResultConsumer.cs b/Expedience.Api/Consumers/DutyCompletionResultConsumer.cs
index 2f2a357..5a7cc52 100644
--- a/Expedience.Api/Consumers/DutyCompletionResultConsumer.cs
+++ b/Expedience.Api/Consumers/DutyCompletionResultConsumer.cs
@@ -64,7 +64,15 @@ namespace Expedience.Api.Consumers
                 UploadedAt = message.UploadDateUtc,
             };
 
-            dbContext.DutyCompletionResults.Add(completionResult);
+            var dutyCompletionResult = dbContext.DutyCompletionResults.FirstOrDefault(d => d.Id == message.UploadId);
+            if (dutyCompletionResult == null)
+            {
+                dbContext.DutyCompletionResults.Add(completionResult);
+            }
+            else
+            {
+                _logger.LogWarning($"The Result with Id {message.Uploadid} has already been uploaded");
+            }
 
             // Insert this territory if it does not exist
             var territory = dbContext.Territories.FirstOrDefault(t => t.TerritoryId == completionResult.TerritoryId);