Quick fix for async projection shard names. Closes GH-3165

JasperFx · May 6, 2024 · ff6df64 · ff6df64
1 parent 7af77cd
commit ff6df64
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 4 deletions.
diff --git a/docs/documents/querying/linq/include.md b/docs/documents/querying/linq/include.md
@@ -246,4 +246,4 @@ var found = batch.Query<Issue>()
     .Single();
 ```
 <sup><a href='https://github.com/JasperFx/marten/blob/master/src/LinqTests/Includes/end_to_end_query_with_include.cs#L42-L51' title='Snippet source file'>snippet source</a> | <a href='#snippet-sample_batch_include' title='Start of snippet'>anchor</a></sup>
-<!-- endSnippet -->
+<!-- endSnippet -->
diff --git a/docs/events/projections/multi-stream-projections.md b/docs/events/projections/multi-stream-projections.md
@@ -314,12 +314,12 @@ public class LicenseFeatureToggledEventGrouper: IAggregateGrouper<Guid>
 
         // TODO -- let's build more samples first, but see if there's a useful
         // pattern for the next 3/4 operations later
-        var licenceIds = licenseFeatureTogglesEvents
+        var licenseIds = licenseFeatureTogglesEvents
             .Select(e => e.Data.LicenseId)
             .ToList();
 
         var result = await session.Query<UserFeatureToggles>()
-            .Where(x => licenceIds.Contains(x.LicenseId))
+            .Where(x => licenseIds.Contains(x.LicenseId))
             .Select(x => new {x.Id, x.LicenseId})
             .ToListAsync();
 

diff --git a/docs/events/quickstart.md b/docs/events/quickstart.md
@@ -241,4 +241,4 @@ await using (var session = store.LightweightSession())
 }
 ```
 <sup><a href='https://github.com/JasperFx/marten/blob/master/src/EventSourcingTests/Examples/event_store_quickstart.cs#L93-L108' title='Snippet source file'>snippet source</a> | <a href='#snippet-sample_events-aggregate-on-the-fly' title='Start of snippet'>anchor</a></sup>
-<!-- endSnippet -->
+<!-- endSnippet -->
diff --git a/src/Marten/AdvancedOperations.cs b/src/Marten/AdvancedOperations.cs
@@ -7,6 +7,7 @@
 using Marten.Events;
 using Marten.Events.Daemon;
 using Marten.Events.Daemon.HighWater;
+using Marten.Events.Projections;
 using Marten.Events.TestSupport;
 using Marten.Schema;
 using Marten.Storage;
@@ -182,6 +183,7 @@ public IReadOnlyList<ShardName> AllAsyncProjectionShardNames()
             .Options
             .Projections
             .All
+            .Where(x => x.Lifecycle == ProjectionLifecycle.Async)
             .SelectMany(x => x.AsyncProjectionShards(_store))
             .Select(x => x.Name)
             .ToList();