From 5022e2d94b548da121dc4cc802b9118e6ff34bef Mon Sep 17 00:00:00 2001 From: Luke Tomlinson Date: Fri, 19 Jan 2024 12:22:22 -0800 Subject: [PATCH] reenable session migration --- src/Runner.Listener/MessageListener.cs | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/src/Runner.Listener/MessageListener.cs b/src/Runner.Listener/MessageListener.cs index 4954773c7..48c4e7548 100644 --- a/src/Runner.Listener/MessageListener.cs +++ b/src/Runner.Listener/MessageListener.cs @@ -102,13 +102,13 @@ namespace GitHub.Runner.Listener taskAgentSession, token); - // if (_session.SessionMigrationURI != null) - // { - // Trace.Info($"Runner session is in migration mode: Creating Broker session with SessionMigrationURI: {0}", _session.SessionMigrationURI); - // var brokerServer = HostContext.GetService(); - // await brokerServer.ConnectAsync(_session.SessionMigrationURI, _creds); - // _session = await brokerServer.CreateSessionAsync(token, taskAgentSession); - // } + if (_session.BrokerMigrationMessage != null) + { + Trace.Info($"Runner session is in migration mode: Creating Broker session with BrokerBaseUrl: {0}", _session.BrokerMigrationMessage.BrokerBaseUrl); + var brokerServer = HostContext.GetService(); + await brokerServer.ConnectAsync(_session.BrokerMigrationMessage.BrokerBaseUrl, _creds); + _session = await brokerServer.CreateSessionAsync(token, taskAgentSession); + } Trace.Info($"Session created."); if (encounteringError)