Global partitioning: a scheduled message runs on a node that does not own the slot, with the same group id #4673

public interface ISagaMessage
{
    Guid Id { get; }
}

public record StartSaga(Guid Id) : ISagaMessage;

public record Tick(Guid Id, int Number) : ISagaMessage;

public class ReproSaga : Saga
{
    public const int TickCount = 10;
    public static readonly List<string> Log = [];

    public Guid Id { get; set; }

    public static (ReproSaga, OutgoingMessages) Start(StartSaga start, Envelope envelope, IWolverineRuntime runtime)
    {
        Log.Add($"StartSaga handled by node number {runtime.DurabilitySettings.AssignedNodeNumber} ({envelope.Destination})");
        return (new ReproSaga { Id = start.Id }, [new Tick(start.Id, 1).ScheduledAt(DateTimeOffset.UtcNow.AddSeconds(1))]);
    }

    public OutgoingMessages Handle(Tick tick, Envelope envelope, IWolverineRuntime runtime)
    {
        Log.Add($"Tick {tick.Number} handled by node number {runtime.DurabilitySettings.AssignedNodeNumber} ({envelope.Destination})");
        if (tick.Number < TickCount)
        {
            return [new Tick(Id, tick.Number + 1).ScheduledAt(DateTimeOffset.UtcNow.AddSeconds(1))];
        }

        MarkCompleted();
        return [];
    }
}

       ....
        .UseWolverine(opts =>
        {
            opts.Durability.Mode = DurabilityMode.Balanced;
            opts.PersistMessagesWithPostgresql(connectionString, "repro")
                .EnableMessageTransport(t => t.TransportSchemaName("repro_queues").AutoProvision());
            opts.Services.AddResourceSetupOnStartup();

            opts.MessagePartitioning.ByMessage<ISagaMessage>(m => m.Id.ToString())
                .GlobalPartitioned(topology =>
                {
                    topology.UseShardedPostgresqlQueues("repro", 2);
                    topology.Message<StartSaga>();
                    topology.Message<Tick>();
                });
        })