Don't return the count, so cache invalidation could happen (on a gene…

…ric level)
FoundatioFx · Oct 2, 2024 · 59df73b · 59df73b
1 parent f88defa
commit 59df73b
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/Foundatio.Repositories.Elasticsearch/Repositories/ElasticRepositoryBase.cs b/src/Foundatio.Repositories.Elasticsearch/Repositories/ElasticRepositoryBase.cs
@@ -746,9 +746,6 @@ public virtual async Task<long> PatchAllAsync(IRepositoryQuery query, IPatchOper
                     var delay = TimeSpan.FromSeconds(attempts <= 5 ? 1 : 5);
                     await Task.Delay(delay).AnyContext();
                 } while (true);
-
-                // TODO: Add cache invalidation.
-                return affectedRecords;
             }
             else
             {
@@ -816,6 +813,7 @@ public virtual async Task<long> PatchAllAsync(IRepositoryQuery query, IPatchOper
         {
             if (IsCacheEnabled)
                 await InvalidateCacheByQueryAsync(query.As<T>());
+
             await OnDocumentsChangedAsync(ChangeType.Saved, EmptyList, options).AnyContext();
             await SendQueryNotificationsAsync(ChangeType.Saved, query, options).AnyContext();
         }