Bump Microsoft.Orleans.Streaming from 10.2.0 to 10.3.1

[dependabot]

Pinned Microsoft.Orleans.Streaming at 10.3.1.

Release notes

Sourced from Microsoft.Orleans.Streaming's releases.

10.3.1

The most significant change in this release over 10.3.0 is the format used by the version contract compatibility analyzers. The other changes are test and docs fixes.

What's Changed

• Enable DefaultDeny network isolation for CI by @​ReubenBond in Enable DefaultDeny network isolation for CI dotnet/orleans#10850
• docs: add placement hint guidance by @​ReubenBond in docs: add placement hint guidance dotnet/orleans#10844
• fix(test): propagate xUnit cancellation by @​ReubenBond in fix(test): propagate xUnit cancellation dotnet/orleans#10845
• fix(codegen): suppress warnings in generated source by @​ReubenBond in fix(codegen): suppress warnings in generated source dotnet/orleans#10854
• test(codegen): pass cancellation token to diagnostics by @​ReubenBond in test(codegen): pass cancellation token to diagnostics dotnet/orleans#10878
• ci: add trusted coverage report validation by @​ReubenBond in ci: add trusted coverage report validation dotnet/orleans#10882
• fix(test): remove activation-local reminder waits by @​ReubenBond in fix(test): remove activation-local reminder waits dotnet/orleans#10855
• test(dashboard): cover hosting and routing behavior by @​ReubenBond in test(dashboard): cover hosting and routing behavior dotnet/orleans#10885
• test(streaming): cover JSON converter read contracts by @​ReubenBond in test(streaming): cover JSON converter read contracts dotnet/orleans#10884
• test(testing): cover TestingHost failure diagnostics by @​ReubenBond in test(testing): cover TestingHost failure diagnostics dotnet/orleans#10883
• test(analyzers): raise compiler tooling coverage by @​ReubenBond in test(analyzers): raise compiler tooling coverage dotnet/orleans#10894
• test(azure): cover queue JSON validation by @​ReubenBond in test(azure): cover queue JSON validation dotnet/orleans#10876
• refactor(codegen): remove unused method signature comparer by @​ReubenBond in refactor(codegen): remove unused method signature comparer dotnet/orleans#10874
• test(runtime): cover ring range collection invariants by @​ReubenBond in test(runtime): cover ring range collection invariants dotnet/orleans#10879
• test(serialization): cover multidimensional array copying by @​ReubenBond in test(serialization): cover multidimensional array copying dotnet/orleans#10880
• test(transactions): verify consistency histories by @​ReubenBond in test(transactions): verify consistency histories dotnet/orleans#10875
• test(adonet): raise relational provider coverage above 90% by @​ReubenBond in test(adonet): raise relational provider coverage above 90% dotnet/orleans#10892
• test(reminders): harden lifecycle synchronization by @​ReubenBond in test(reminders): harden lifecycle synchronization dotnet/orleans#10891
• fix(test): remove placement timeout race by @​ReubenBond in fix(test): remove placement timeout race dotnet/orleans#10898
• fix(testing): isolate reminder event continuations by @​ReubenBond in fix(testing): isolate reminder event continuations dotnet/orleans#10899
• test(reminders): add lifecycle conformance scenarios by @​ReubenBond in test(reminders): add lifecycle conformance scenarios dotnet/orleans#10896
• fix(test): keep observer cancellation targets alive by @​ReubenBond in fix(test): keep observer cancellation targets alive dotnet/orleans#10897
• fix(test): retry SQL Server deadlock victims by @​ReubenBond in fix(test): retry SQL Server deadlock victims dotnet/orleans#10901
• test(reminders): enable provider failover coverage by @​ReubenBond in test(reminders): enable provider failover coverage dotnet/orleans#10895
• feat(analyzers): regenerate Orleans contracts project-wide by @​ReubenBond in feat(analyzers): regenerate Orleans contracts project-wide dotnet/orleans#10869
• fix(analyzers): clarify Orleans contract identities by @​ReubenBond in fix(analyzers): clarify Orleans contract identities dotnet/orleans#10910

Full Changelog: dotnet/orleans@v10.3.0...v10.3.1

10.3.0

Orleans 10.3.0

Orleans 10.3.0 expands the platform across clustering, streaming, persistence, integrations, serialization, and developer tooling while delivering a broad reliability and performance pass. Major outcomes include stronger distributed-directory and membership behavior, new streaming and storage providers, hardened transactions and durable jobs, incremental source generation, safer JSON storage deserialization, and new application templates. Alongside these features and fixes, the release optimizes key runtime paths, comprehensively refreshes the docs, strengthens testing and CI, and updates dependencies and repository maintenance.

Compatibility notes

[!IMPORTANT]
Review these changes before upgrading. This release contains three intentionally behavior-changing updates.

• Default JSON storage serializer type allow-list (#​10268). The default Newtonsoft.Json-based Orleans storage serializer now resolves $type metadata only for types permitted by Orleans' configured type filters and manifest. Existing wire data remains readable when its types are allowed; [GenerateSerializer] types and standard permitted BCL types continue to work without changes. If persisted, streamed, or transactional JSON contains other types, reads now fail with an actionable JsonSerializationException. Prefer registering those types through TypeManifestOptions.AllowedTypes, [GenerateSerializer], ITypeNameFilter, or ITypeFilter; OrleansJsonSerializerOptions.AllowAllTypes = true restores the former permissive JSON behavior when a narrowly scoped allow-list is not practical.
• Updated RPC semantic convention keys (#​10354). Orleans activities now emit the current OpenTelemetry RPC key rpc.system.name; Orleans-specific service, target, and source metadata move to orleans.rpc.service, orleans.rpc.target_id, and orleans.rpc.source_id. The runtime-side rpc.method value is now qualified as <interface>/<method>, and affected ActivitySource versions are incremented. Update dashboards, alerts, collectors, and queries which depend on the legacy rpc.system, rpc.service, rpc.orleans.target_id, or rpc.orleans.source_id keys or the previous method value.
• Grain context configured before construction (#​10565). Orleans now deterministically applies IConfigureGrainContext actions before grain construction, so constructors can observe fully configured context state. Custom IGrainContextActivator implementations must migrate from CreateContext(GrainAddress) to CreateContext(GrainAddress, IConfigureGrainContext[]) and apply the supplied configurators before constructing the grain. Stateless-worker configurators continue to apply to the outer stateless-worker context.

Highlights

Runtime, clustering & resilience

• Distributed-directory rolling upgrades now have durable handoffs, cancellation-aware operations, stronger single-activation guarantees, and improved recovery and startup behavior (#​10309, #​10323, #​10339, #​9958, #​10500, #​10533, #​10613, #​10625).
• Membership fault detection gains connection liveness checks, adaptive probe timeouts, retained local health history, and local-stall detection (#​9978, #​10510, #​10502, #​9979).
• Reminder delivery, reconciliation, rebalancing, shutdown state, placement compatibility caching, and resilience policies received substantial correctness and efficiency improvements (#​10296, #​10430, #​10612, #​10819, #​10838, #​10311, #​10313, #​10614, #​10573, #​10596, #​10314, #​10597, #​10599, #​9819).

Streaming

• New AWS Kinesis support, SQS data adapters with FIFO support, Event Hubs Aspire integration, grain-backed checkpointing, and generalized Azure Table checkpointing broaden deployment choices (#​8967, #​8723, #​9328, #​10345, #​10355).
• Persistent streams now flow cancellation; stateless workers can consume streams; Azure Queue migration supports compact JSON; and stream telemetry includes richer tags (#​10383, #​10657, #​10507, #​8631).
• Redis implicit subscriptions, SQL Server queue commits, ADO.NET handoffs, batched acknowledgements, implicit rewind handling, and memory/Event Hubs hot paths were hardened or optimized (#​10423, #​10572, #​10536, #​10574, #​10655, #​10662, #​10550, #​10767).

Storage, persistence, journaling, durable jobs & transactions

• New Azure Table and Redis journal providers, DynamoDB transactional storage, file-based grain storage, and a System.Text.Json grain storage serializer expand persistence options (#​10254, #​9823, #​9616, #​9537, #​10806, #​9505).
• Transactions receive extensive conflict, recovery, retry, isolation, cancellation, and diagnostics hardening across providers (#​10372, #​10376, #​10382, #​10375, #​10374, #​10385, #​10545, #​10743).
• Persistent state is now concurrency-safe and cancellation-aware, while journaling snapshot operations and durable-job retry/rescheduling semantics are more robust (#​10255, #​10641, #​10800, #​10681, #​10349, #​10547, #​10716, #​10679).

Providers & integrations

• Google Cloud Firestore providers, Cosmos DB custom document IDs and partition keys, ADO.NET DbDataSource support, and improved Azure, ZooKeeper, Redis, NATS, and relational-provider behavior extend and stabilize integrations (#​8462, #​8699, #​10326, #​10429, #​10381, #​10437, #​10835, #​10422, #​10505, #​10276).
• SQL Server, PostgreSQL, and MySQL clustering add the missing defunct-silo cleanup query (#​8811, #​9125, #​8896).

Serialization, code generation & analyzers

• The source generator is now incremental, generates provider metadata at build time, avoids runtime provider scanning, and supports record-parameter field IDs and custom grain-call return types (#​10035, #​10493, #​10566, #​10495, #​10682).
• Serialization reduces codec and buffer allocations, adds type/assembly allow-list helpers, and clarifies type-trust configuration (#​10301, #​10340, #​10668, #​10228, #​10424).
• Analyzers detect RPC contract changes and provide improved diagnostic guidance (#​10337, #​10832).

Developer experience, templates, samples & docs

• New Orleans application templates and a basic clustering sample make it easier to start and validate applications (#​10646, #​10690, #​10622).
• Connection middleware abstractions and framing helpers provide new transport extension points (#​10136, #​10433).
• The docs were comprehensively reorganized and modernized across onboarding, architecture, grains, hosting, operations, security, observability, persistence, streaming, testing, deployment, migration, and production guidance (#​10331, #​10332, #​10334, #​10335, #​10327, #​10328, #​10333, #​10330, #​10336, #​10329, #​10675, #​10746).
• Test infrastructure moved to xUnit v3 and Microsoft.Testing.Platform, with provider conformance kits, published test results, coverage reporting, and extensive reliability improvements (#​10722, #​10726, #​10490, #​10785, #​10730, #​10733, #​10842, #​10438, #​10738).
  ... (truncated)

10.3.0-rc.1

What's Changed

• ci: enable GitHub autobaseline for nightly-main pipeline by @​ReubenBond in ci: enable GitHub autobaseline for nightly-main pipeline dotnet/orleans#10297
• fix(reminders): prevent ticks after unregister by @​ReubenBond in fix(reminders): prevent ticks after unregister dotnet/orleans#10296
• feat(streaming): make SequentialItem serializable by @​ReubenBond in feat(streaming): make SequentialItem serializable dotnet/orleans#10302
• Add Azure Table journal storage provider by @​danielmeza in Add Azure Table journal storage provider dotnet/orleans#10254
• fix(serialization): defer interface collection codec dependencies by @​ReubenBond in fix(serialization): defer interface collection codec dependencies dotnet/orleans#10301
• perf(codegen): migrate to incremental source generator by @​ReubenBond in perf(codegen): migrate to incremental source generator dotnet/orleans#10035
• test: use InProcessTestClusterBuilder in Azure stream reliability tests by @​ReubenBond in test: use InProcessTestClusterBuilder in Azure stream reliability tests dotnet/orleans#10222
• chore(deps): bump dompurify from 3.4.11 to 3.4.12 in /src/Dashboard/Orleans.Dashboard.App by @​dependabot[bot] in chore(deps): bump dompurify from 3.4.11 to 3.4.12 in /src/Dashboard/Orleans.Dashboard.App dotnet/orleans#10303
• test: observe grain directory convergence in liveness tests by @​ReubenBond in test: observe grain directory convergence in liveness tests dotnet/orleans#10299
• docs: require conventional commit format for PR titles by @​ReubenBond in docs: require conventional commit format for PR titles dotnet/orleans#10310
• fix(serialization)!: enforce type allow-list in default JSON storage serializer by @​ReubenBond in fix(serialization)!: enforce type allow-list in default JSON storage serializer dotnet/orleans#10268
• feat(serialization): add type and assembly allow-list helpers by @​ReubenBond in feat(serialization): add type and assembly allow-list helpers dotnet/orleans#10228
• fix(testing): track reminder schedules per owner by @​ReubenBond in fix(testing): track reminder schedules per owner dotnet/orleans#10312
• refactor: enable nullable reference types across Orleans by @​ReubenBond in refactor: enable nullable reference types across Orleans dotnet/orleans#10291
• fix: eliminate rebalancer waiter timeout race by @​ReubenBond in fix: eliminate rebalancer waiter timeout race dotnet/orleans#10311
• fix(directory): support rolling upgrades to distributed directory by @​ReubenBond in fix(directory): support rolling upgrades to distributed directory dotnet/orleans#10309
• test: fix grain directory nullability diagnostics by @​ReubenBond in test: fix grain directory nullability diagnostics dotnet/orleans#10315
• fix: clean up rebalancer diagnostic waiters by @​ReubenBond in fix: clean up rebalancer diagnostic waiters dotnet/orleans#10313
• perf(reminders): drop reminders that are not due soon by @​ReubenBond in perf(reminders): drop reminders that are not due soon dotnet/orleans#10259
• perf: cache compatible placement silos by @​ReubenBond in perf: cache compatible placement silos dotnet/orleans#10314
• fix(directory): cancel snapshot pulls from departed silos by @​ReubenBond in fix(directory): cancel snapshot pulls from departed silos dotnet/orleans#10318
• feat(streaming): add telemetry tags to stream metrics by @​oising in feat(streaming): add telemetry tags to stream metrics dotnet/orleans#8631
• test: wait for grain call before checking cancellation by @​ReubenBond in test: wait for grain call before checking cancellation dotnet/orleans#10319
• test(streaming): cover eventhub checkpoint flush on shutdown by @​ReubenBond in test(streaming): cover eventhub checkpoint flush on shutdown dotnet/orleans#10321
• feat(cosmos): support custom document IDs and partition keys by @​ReubenBond in feat(cosmos): support custom document IDs and partition keys dotnet/orleans#8699
• fix(directory): make rolling upgrade handoffs durable by @​ReubenBond in fix(directory): make rolling upgrade handoffs durable dotnet/orleans#10323
• fix: scope reminder test clock to reminder service by @​ReubenBond in fix: scope reminder test clock to reminder service dotnet/orleans#10317
• feat(cosmos): add configuration support for grain storage by @​ReubenBond in feat(cosmos): add configuration support for grain storage dotnet/orleans#10326
• feat(directory): add cancellation-aware operations by @​ReubenBond in feat(directory): add cancellation-aware operations dotnet/orleans#10339
• fix(directory): stabilize rolling upgrade handoff test by @​ReubenBond in fix(directory): stabilize rolling upgrade handoff test dotnet/orleans#10341
• fix(serialization): cap codec allocations by @​ReubenBond in fix(serialization): cap codec allocations dotnet/orleans#10340
• perf(runtime): reduce activation collection sorting allocations by @​ReubenBond in perf(runtime): reduce activation collection sorting allocations dotnet/orleans#10342
• fix(directory): strengthen single-activation guarantees by @​ledjon-behluli in fix(directory): strengthen single-activation guarantees dotnet/orleans#9958
• chore(deps): bump postcss from 8.5.15 to 8.5.25 in /src/Dashboard/Orleans.Dashboard.App by @​dependabot[bot] in chore(deps): bump postcss from 8.5.15 to 8.5.25 in /src/Dashboard/Orleans.Dashboard.App dotnet/orleans#10305
• docs: add Orleans 10 migration guides by @​ReubenBond in docs: add Orleans 10 migration guides dotnet/orleans#10329
• docs: modernize deployment and operations guidance by @​ReubenBond in docs: modernize deployment and operations guidance dotnet/orleans#10327
• docs: modernize grain programming guidance by @​ReubenBond in docs: modernize grain programming guidance dotnet/orleans#10334
• fix(docs): correct timer migration link by @​ReubenBond in fix(docs): correct timer migration link dotnet/orleans#10347
• fix(testing): wait for async cleanup timer rearm by @​ReubenBond in fix(testing): wait for async cleanup timer rearm dotnet/orleans#10348
• chore(deps-dev): bump fast-uri from 3.1.4 to 3.1.5 in /docs/site by @​dependabot[bot] in chore(deps-dev): bump fast-uri from 3.1.4 to 3.1.5 in /docs/site dotnet/orleans#10343
• fix(durablejobs): preserve job state across retries by @​ReubenBond in fix(durablejobs): preserve job state across retries dotnet/orleans#10349
• feat: add connection middleware abstractions and framing helpers by @​wenwangcode in feat: add connection middleware abstractions and framing helpers dotnet/orleans#10136
• docs: modernize security and observability guidance by @​ReubenBond in docs: modernize security and observability guidance dotnet/orleans#10328
• docs: restore migration reference links by @​ReubenBond in docs: restore migration reference links dotnet/orleans#10352
• docs: restore authoritative grain references by @​ReubenBond in docs: restore authoritative grain references dotnet/orleans#10353
• docs: modernize hosting and configuration guidance by @​ReubenBond in docs: modernize hosting and configuration guidance dotnet/orleans#10335
• docs: expand Orleans architecture documentation by @​ReubenBond in docs: expand Orleans architecture documentation dotnet/orleans#10332
• refactor(streaming): remove unused implicit subscriber grain factory by @​ReubenBond in refactor(streaming): remove unused implicit subscriber grain factory dotnet/orleans#10322
• docs: modernize Orleans onboarding by @​ReubenBond in docs: modernize Orleans onboarding dotnet/orleans#10331
  ... (truncated)

10.2.2

What's Changed

• test: speed up shutdown timer readiness tests by @​ReubenBond in test: speed up shutdown timer readiness tests dotnet/orleans#10214
• fix: respect placement hints in local-first directors by @​ReubenBond in fix: respect placement hints in local-first directors dotnet/orleans#10217
• fix: serialize immutable dictionary value comparers by @​ReubenBond in fix: serialize immutable dictionary value comparers dotnet/orleans#10225
• perf(manifest): reduce cluster manifest payload size by @​ReubenBond in perf(manifest): reduce cluster manifest payload size dotnet/orleans#10224
• fix: exclude non-Active silos from placement by @​ReubenBond in fix: exclude non-Active silos from placement dotnet/orleans#10219
• fix(azure): allow configuring journal blob names by @​ReubenBond in fix(azure): allow configuring journal blob names dotnet/orleans#10230
• feat: prune excess defunct membership entries by @​ReubenBond in feat: prune excess defunct membership entries dotnet/orleans#10231
• fix: clear stale message receiver cache for forwarded silo messages by @​ReubenBond in fix: clear stale message receiver cache for forwarded silo messages dotnet/orleans#10235
• revert: remove fast-path message destination cache by @​ReubenBond in revert: remove fast-path message destination cache dotnet/orleans#10243
• chore(deps): bump dompurify from 3.4.7 to 3.4.11 in /src/Dashboard/Orleans.Dashboard.App by @​dependabot[bot] in chore(deps): bump dompurify from 3.4.7 to 3.4.11 in /src/Dashboard/Orleans.Dashboard.App dotnet/orleans#10233
• chore(deps-dev): bump vite from 8.0.11 to 8.0.16 in /src/Dashboard/Orleans.Dashboard.App by @​dependabot[bot] in chore(deps-dev): bump vite from 8.0.11 to 8.0.16 in /src/Dashboard/Orleans.Dashboard.App dotnet/orleans#10229
• serialization: Allow enums when no type filter has an opinion by @​Tragetaschen in serialization: Allow enums when no type filter has an opinion dotnet/orleans#10234
• chore(deps-dev): bump js-yaml from 4.1.1 to 4.3.0 in /src/Dashboard/Orleans.Dashboard.App by @​dependabot[bot] in chore(deps-dev): bump js-yaml from 4.1.1 to 4.3.0 in /src/Dashboard/Orleans.Dashboard.App dotnet/orleans#10240
• perf: add span formatting for membership snapshots by @​ReubenBond in perf: add span formatting for membership snapshots dotnet/orleans#10248
• chore(deps-dev): bump @​babel/core from 7.29.0 to 7.29.7 in /src/Dashboard/Orleans.Dashboard.App by @​dependabot[bot] in chore(deps-dev): bump @babel/core from 7.29.0 to 7.29.7 in /src/Dashboard/Orleans.Dashboard.App dotnet/orleans#10241
• fix(streaming): use overflow-safe comparison for cached message sequence numbers by @​fernando-takeshi in fix(streaming): use overflow-safe comparison for cached message sequence numbers dotnet/orleans#10245
• [Automated] Update API Surface Area by @​github-actions[bot] in [Automated] Update API Surface Area dotnet/orleans#10223
• Auto-generated baselines by 1ES Pipeline Templates by @​ReubenBond in Auto-generated baselines by 1ES Pipeline Templates dotnet/orleans#10250
• fix: update MessagePack dependency by @​ReubenBond in fix: update MessagePack dependency dotnet/orleans#10251
• feat: add SiloAddress parse interfaces by @​ReubenBond in feat: add SiloAddress parse interfaces dotnet/orleans#10256
• fix: use explicit address equality by @​ReubenBond in fix: use explicit address equality dotnet/orleans#10257
• fix(reminders): fix scheduling for long due times by @​ReubenBond in fix(reminders): fix scheduling for long due times dotnet/orleans#10260
• fix(runtime): stop retrying dead directory members by @​ReubenBond in fix(runtime): stop retrying dead directory members dotnet/orleans#10261
• fix: fence silos missing from newer membership views by @​ReubenBond in fix: fence silos missing from newer membership views dotnet/orleans#10262
• [Automated] Update API Surface Area by @​github-actions[bot] in [Automated] Update API Surface Area dotnet/orleans#10252
• fix(streaming): don't recycle in-flight pooled buffers mid-batch by @​ReubenBond in fix(streaming): don't recycle in-flight pooled buffers mid-batch dotnet/orleans#10264
• [Automated] Update API Surface Area by @​github-actions[bot] in [Automated] Update API Surface Area dotnet/orleans#10265
• fix(streaming): refresh idle EventHub cursors to avoid QueueCacheMissException by @​ReubenBond in fix(streaming): refresh idle EventHub cursors to avoid QueueCacheMissException dotnet/orleans#10266
• fix(membership): retain recently-declared-dead entries during pruning by @​ReubenBond in fix(membership): retain recently-declared-dead entries during pruning dotnet/orleans#10269
• fix(runtime): fault outstanding callbacks when a host shuts down by @​ReubenBond in fix(runtime): fault outstanding callbacks when a host shuts down dotnet/orleans#10275
• feat(serialization): add codecs for FrozenDictionary and FrozenSet by @​ReubenBond in feat(serialization): add codecs for FrozenDictionary and FrozenSet dotnet/orleans#10270
• fix(testinghost): dispose stopped in-process silo hosts without leaking or hanging by @​ReubenBond in fix(testinghost): dispose stopped in-process silo hosts without leaking or hanging dotnet/orleans#10272
• chore(deps): bump dotnet-sdk from 10.0.301 to 10.0.302 by @​dependabot[bot] in chore(deps): bump dotnet-sdk from 10.0.301 to 10.0.302 dotnet/orleans#10267
• Resolve TimeProvider via keyed DI per subsystem (fixes FakeTimeProvider timer test CI hang) by @​ReubenBond in Resolve TimeProvider via keyed DI per subsystem (fixes FakeTimeProvider timer test CI hang) dotnet/orleans#10271
• [Automated] Update API Surface Area by @​github-actions[bot] in [Automated] Update API Surface Area dotnet/orleans#10277
• fix(runtime): close callback admission during shutdown by @​ReubenBond in fix(runtime): close callback admission during shutdown dotnet/orleans#10290
• fix(streaming): bound Event Hubs shutdown by @​ReubenBond in fix(streaming): bound Event Hubs shutdown dotnet/orleans#10288
• fix(durable-jobs): treat shutdown cancellation as normal by @​ReubenBond in fix(durable-jobs): treat shutdown cancellation as normal dotnet/orleans#10285
• fix: resolve component governance dependency alerts by @​ReubenBond in fix: resolve component governance dependency alerts dotnet/orleans#10287
• chore(ci): complete 1ES autobaselining and branch controls by @​ReubenBond in chore(ci): complete 1ES autobaselining and branch controls dotnet/orleans#10284
• fix(streaming): avoid LeaseBasedQueueBalancer timer disposal race during shutdown by @​ReubenBond in fix(streaming): avoid LeaseBasedQueueBalancer timer disposal race during shutdown dotnet/orleans#10286
• fix(runtime): avoid service resolution after silo shutdown by @​ReubenBond in fix(runtime): avoid service resolution after silo shutdown dotnet/orleans#10289
• [Automated] Update API Surface Area by @​github-actions[bot] in [Automated] Update API Surface Area dotnet/orleans#10293
• fix(runtime): transition silo status before grain deactivation by @​ReubenBond in fix(runtime): transition silo status before grain deactivation dotnet/orleans#10294
• chore(deps-dev): bump brace-expansion from 1.1.12 to 1.1.16 in /src/Dashboard/Orleans.Dashboard.App by @​dependabot[bot] in chore(deps-dev): bump brace-expansion from 1.1.12 to 1.1.16 in /src/Dashboard/Orleans.Dashboard.App dotnet/orleans#10292
• fix(ci): upload CodeQL results together by @​ReubenBond in fix(ci): upload CodeQL results together dotnet/orleans#10295

New Contributors

• @​fernando-takeshi made their first contribution in fix(streaming): use overflow-safe comparison for cached message sequence numbers dotnet/orleans#10245
  ... (truncated)

10.2.2-rc.2

What's Changed

• fix: use explicit address equality by @​ReubenBond in fix: use explicit address equality dotnet/orleans#10257
• fix(reminders): fix scheduling for long due times by @​ReubenBond in fix(reminders): fix scheduling for long due times dotnet/orleans#10260
• fix(runtime): stop retrying dead directory members by @​ReubenBond in fix(runtime): stop retrying dead directory members dotnet/orleans#10261
• fix: fence silos missing from newer membership views by @​ReubenBond in fix: fence silos missing from newer membership views dotnet/orleans#10262
• [Automated] Update API Surface Area by @​github-actions[bot] in [Automated] Update API Surface Area dotnet/orleans#10252
• fix(streaming): don't recycle in-flight pooled buffers mid-batch by @​ReubenBond in fix(streaming): don't recycle in-flight pooled buffers mid-batch dotnet/orleans#10264
• [Automated] Update API Surface Area by @​github-actions[bot] in [Automated] Update API Surface Area dotnet/orleans#10265
• fix(streaming): refresh idle EventHub cursors to avoid QueueCacheMissException by @​ReubenBond in fix(streaming): refresh idle EventHub cursors to avoid QueueCacheMissException dotnet/orleans#10266

Full Changelog: dotnet/orleans@v10.2.2-rc.1...v10.2.2-rc.2

10.2.2-rc.1

What's Changed

• test: speed up shutdown timer readiness tests by @​ReubenBond in test: speed up shutdown timer readiness tests dotnet/orleans#10214
• fix: respect placement hints in local-first directors by @​ReubenBond in fix: respect placement hints in local-first directors dotnet/orleans#10217
• fix: serialize immutable dictionary value comparers by @​ReubenBond in fix: serialize immutable dictionary value comparers dotnet/orleans#10225
• perf(manifest): reduce cluster manifest payload size by @​ReubenBond in perf(manifest): reduce cluster manifest payload size dotnet/orleans#10224
• fix: exclude non-Active silos from placement by @​ReubenBond in fix: exclude non-Active silos from placement dotnet/orleans#10219
• fix(azure): allow configuring journal blob names by @​ReubenBond in fix(azure): allow configuring journal blob names dotnet/orleans#10230
• feat: prune excess defunct membership entries by @​ReubenBond in feat: prune excess defunct membership entries dotnet/orleans#10231
• fix: clear stale message receiver cache for forwarded silo messages by @​ReubenBond in fix: clear stale message receiver cache for forwarded silo messages dotnet/orleans#10235
• revert: remove fast-path message destination cache by @​ReubenBond in revert: remove fast-path message destination cache dotnet/orleans#10243
• chore(deps): bump dompurify from 3.4.7 to 3.4.11 in /src/Dashboard/Orleans.Dashboard.App by @​dependabot[bot] in chore(deps): bump dompurify from 3.4.7 to 3.4.11 in /src/Dashboard/Orleans.Dashboard.App dotnet/orleans#10233
• chore(deps-dev): bump vite from 8.0.11 to 8.0.16 in /src/Dashboard/Orleans.Dashboard.App by @​dependabot[bot] in chore(deps-dev): bump vite from 8.0.11 to 8.0.16 in /src/Dashboard/Orleans.Dashboard.App dotnet/orleans#10229
• serialization: Allow enums when no type filter has an opinion by @​Tragetaschen in serialization: Allow enums when no type filter has an opinion dotnet/orleans#10234
• chore(deps-dev): bump js-yaml from 4.1.1 to 4.3.0 in /src/Dashboard/Orleans.Dashboard.App by @​dependabot[bot] in chore(deps-dev): bump js-yaml from 4.1.1 to 4.3.0 in /src/Dashboard/Orleans.Dashboard.App dotnet/orleans#10240
• perf: add span formatting for membership snapshots by @​ReubenBond in perf: add span formatting for membership snapshots dotnet/orleans#10248
• chore(deps-dev): bump @​babel/core from 7.29.0 to 7.29.7 in /src/Dashboard/Orleans.Dashboard.App by @​dependabot[bot] in chore(deps-dev): bump @babel/core from 7.29.0 to 7.29.7 in /src/Dashboard/Orleans.Dashboard.App dotnet/orleans#10241
• fix(streaming): use overflow-safe comparison for cached message sequence numbers by @​fernando-takeshi in fix(streaming): use overflow-safe comparison for cached message sequence numbers dotnet/orleans#10245
• [Automated] Update API Surface Area by @​github-actions[bot] in [Automated] Update API Surface Area dotnet/orleans#10223
• Auto-generated baselines by 1ES Pipeline Templates by @​ReubenBond in Auto-generated baselines by 1ES Pipeline Templates dotnet/orleans#10250
• fix: update MessagePack dependency by @​ReubenBond in fix: update MessagePack dependency dotnet/orleans#10251
• feat: add SiloAddress parse interfaces by @​ReubenBond in feat: add SiloAddress parse interfaces dotnet/orleans#10256

New Contributors

• @​fernando-takeshi made their first contribution in fix(streaming): use overflow-safe comparison for cached message sequence numbers dotnet/orleans#10245

Full Changelog: dotnet/orleans@v10.2.0...v10.2.2-rc.1

10.2.1

Reverts the message destination receiver cache changes from dotnet/orleans#10064 (commit: dotnet/orleans@d3c2af3)

Full Changelog: dotnet/orleans@v10.2.0...v10.2.1

Commits viewable in compare view.

[Copilot]

Copilot review overview

🟡 Changes recommended

Align the related Orleans package versions or document a supported mixed-version configuration.

Get a fresh assessment by requesting another Copilot review.

Review effort: Lite
Findings: 1

Open (1)

• Align all Orleans package references to version 10.3.1 · New

What changed in this PR

Updates Microsoft.Orleans.Streaming from 10.2.0 to 10.3.1.

Changes:

• Bumps the centrally managed streaming package version.

File	Description
Directory.Packages.props	Updates Orleans Streaming to 10.3.1 while related Orleans packages remain at 10.2.0.

---

💡 Add a code-review agent skill or configure MCP servers for context-aware, tailored reviews. Learn more in the docs.

[Copilot]

Copilot review overview

🟡 Changes recommended

Cancellation tokens are currently ignored by the receiver during message polling and delivery.

Get a fresh assessment by requesting another Copilot review.

Review effort: Lite
Findings: 1

Open (1)

• Propagate cancellation in Kafka receiver message delivery · New

Resolved since last review (1)

• Align all Orleans package references to version 10.3.1

[Copilot]

Copilot review overview

🟡 Changes recommended

Cancellation can be ignored after idle polling, and the new cancellation behavior lacks focused test coverage.

Get a fresh assessment by requesting another Copilot review.

Review effort: Lite
Findings: 1

Open (1)

• The new cancellation-aware receiver behavior is not actually covered: all updated callers pass… · New

Resolved since last review (1)

• Propagate cancellation in Kafka receiver message delivery

[Copilot]

Copilot review overview

🟡 Changes recommended

Cancellation can advance Kafka positions and skip uncommitted records; the unrelated Testcontainers.Kafka upgrade also needs justification or separation.

Get a fresh assessment by requesting another Copilot review.

Review effort: Lite
Findings: 1

Open (1)

• Restore consumer position when Consume is canceled · New

Resolved since last review (1)

• The new cancellation-aware receiver behavior is not actually covered: all updated callers pass…

[Copilot]

Copilot review overview

🟡 Changes recommended

Three moderate issues remain in Kafka cancellation handling and rollback-path test coverage.

Get a fresh assessment by requesting another Copilot review.

Review effort: Lite
Findings: 2

Open (2)

• Cancellation is ignored after timed-out Consume · New
• Canceled token is ignored when receiver is unavailable · New

Resolved since last review (1)

• Restore consumer position when Consume is canceled

[Copilot]

Copilot review overview

🟡 Changes recommended

Offset rollback can lose messages, and cancellation replay lacks the required regression coverage.

Get a fresh assessment by requesting another Copilot review.

Review effort: Lite
Findings: 1

Open (1)

• Treat offset restoration failure as fatal to prevent message loss · New

Resolved since last review (2)

• Canceled token is ignored when receiver is unavailable
• Cancellation is ignored after timed-out Consume

[Copilot]

Copilot encountered an error and was unable to review this pull request. You can try again by re-requesting a review.

[Copilot]

Copilot review overview

🟡 Changes recommended

Unresolved critical and moderate findings affect offset safety and cancellable provider startup.

Get a fresh assessment by requesting another Copilot review.

Review effort: Lite
Findings: 1 · 1

Open (2)

• Prevent shutdown from losing uncommitted messages · New
• Test rollback and replay after Consume cancellation · New

[Copilot]

Copilot review overview

🟡 Changes recommended

Unresolved cancellation and offset-handling issues remain, including a critical message-skipping risk.

Get a fresh assessment by requesting another Copilot review.

Review effort: Lite
Findings: 1

Open (1)

• Check cancellation before returning the consumed batch · New

Resolved since last review (2)

• Prevent shutdown from losing uncommitted messages
• Test rollback and replay after Consume cancellation

[Copilot]

Copilot review overview

🟡 Changes recommended

Cancellation handling, receiver fault-state behavior, and deterministic replay coverage remain unresolved.

Get a fresh assessment by requesting another Copilot review.

Review effort: Lite
Findings: 1

Open (1)

• Reject reads after fatal consumer restoration failure · New

Resolved since last review (1)

• Check cancellation before returning the consumed batch

Previously missed (2)

In code that hasn't changed since last review

Honor cancellation after waiting for consumer lock

src/​Orleans.Streams.Confluent/​KafkaQueueAdapterReceiver.cs:87

Cancellation is checked before acquiring _consumerSync, but not again in this uninitialized branch. If the caller cancels while waiting for the lock, this returns an empty batch successfully instead of honoring cancellation; check the token immediately before returning the empty list.

This issue also appears in the following locations of the same file:

• line 176
• line 191
• line 196

Make cancellation timing deterministic in restoration test

test/​Orleans.Streams.Confluent.IntegrationTests/​KafkaStreamProviderIntegrationTests.cs:165

The 10 ms cancellation window is nondeterministic and may fire before Consume advances the receiver, allowing this test to pass without exercising read-side offset restoration or replay. Use a deterministic consumer seam/fake, or otherwise arrange cancellation after a poll and verify that the next read replays the batch.

[Copilot]

Copilot review overview

🔵 Needs a closer look

Shutdown can lose an in-flight offset, and the integration test does not deterministically verify offset restoration.

Review effort: Lite
Findings: None

Resolved since last review (1)

• Reject reads after fatal consumer restoration failure

Previously missed (1)

In code that hasn't changed since last review

Make cancellation offset restoration test deterministic

test/​Orleans.Streams.Confluent.IntegrationTests/​KafkaStreamProviderIntegrationTests.cs:165

This test does not deterministically exercise cancellation after Kafka advances the consumer: the 10 ms timer can expire before the first Consume, so it still passes even if no offset is restored. Add a deterministic consumer seam or fake which cancels after a poll and verifies Seek/replay instead of relying on this timing window.