feat: or-1349 restart elastic deamon after rebuild

Informatievlaanderen · Jan 24, 2024 · 9029fbe · 9029fbe
1 parent 33387a8
commit 9029fbe
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/src/AssociationRegistry.Admin.ProjectionHost/Extensions/ProjectionEndpointsExtensions.cs b/src/AssociationRegistry.Admin.ProjectionHost/Extensions/ProjectionEndpointsExtensions.cs
@@ -134,5 +134,7 @@ private static async Task RebuildElasticProjections(
         {
             await elasticClient.Indices.DeleteAsync(indeces, ct: CancellationToken.None).ThrowIfInvalidAsync();
         }
+
+        await projectionDaemon.StartShard($"{ProjectionNames.VerenigingZoeken}:All", CancellationToken.None);
     }
 }
diff --git a/src/AssociationRegistry.Public.ProjectionHost/Extensions/ProjectionEndpointsExtensions.cs b/src/AssociationRegistry.Public.ProjectionHost/Extensions/ProjectionEndpointsExtensions.cs
@@ -43,6 +43,7 @@ public static void AddProjectionEndpoints(this WebApplication app, RebuildConfig
                     await elasticClient.Indices.CreateVerenigingIndexAsync(options.Indices.Verenigingen);
 
                     await projectionDaemon.RebuildProjection(ProjectionNames.VerenigingZoeken,shardTimeout, CancellationToken.None);
+                    await projectionDaemon.StartShard($"{ProjectionNames.VerenigingZoeken}:All", CancellationToken.None);
                 });
 
                 return Results.Accepted();
-Original file line number
+Diff line change
@@ Expand Up / @@ -134,5 +134,7 @@ private static async Task RebuildElasticProjections( @@
             {
                 await elasticClient.Indices.DeleteAsync(indeces, ct: CancellationToken.None).ThrowIfInvalidAsync();
             }
+            await projectionDaemon.StartShard($"{ProjectionNames.VerenigingZoeken}:All", CancellationToken.None);
         }
     }