diff --git a/queries.R b/queries.R
index 4b65e59..1fb608e 100644
--- a/queries.R
+++ b/queries.R
@@ -93,7 +93,7 @@ get_latest_aggregate_losses <- function() {
                 mutate(
                   ncei_priority = case_when(
                     str_like(base_loss_source, "%ncei%") ~ 1,
-                    str_like(base_loss_source, "%ncei%") ~ 2,
+                    str_like(base_loss_source, "%mwr%") ~ 2,
                     TRUE ~ 3
                   )
                 ) %>% 
@@ -347,7 +347,7 @@ async_db_query <- function(query_func, ...) {
       do.call(query_func, args)
     }
   },
-    environment()
+  environment()
   )
   
   return(mirai_call)