diff --git a/Algorithm.Python/ConsolidatorStartTimeRegressionAlgorithm.py b/Algorithm.Python/ConsolidatorStartTimeRegressionAlgorithm.py
index dce98d294dca..78d34dc782dd 100644
--- a/Algorithm.Python/ConsolidatorStartTimeRegressionAlgorithm.py
+++ b/Algorithm.Python/ConsolidatorStartTimeRegressionAlgorithm.py
@@ -40,7 +40,7 @@ def bar_handler(self, _, bar):
if self.time != bar.end_time:
raise RegressionTestException(f"Unexpected consolidation time {bar.Time} != {Time}!")
- self.debug(f"{self.Time} - Consolidation")
+ self.debug(f"{self.time} - Consolidation")
expected = self._expectedConsolidationTime.pop()
if bar.time.time() != expected:
raise RegressionTestException(f"Unexpected consolidation time {bar.time.time()} != {expected}!")
diff --git a/Common/Brokerages/BrokerageMessageType.cs b/Common/Brokerages/BrokerageMessageType.cs
index 89eaa090abe8..03c6c42d9e85 100644
--- a/Common/Brokerages/BrokerageMessageType.cs
+++ b/Common/Brokerages/BrokerageMessageType.cs
@@ -43,6 +43,11 @@ public enum BrokerageMessageType
///
/// Brokerage disconnected from remote server (4)
///
- Disconnect
+ Disconnect,
+
+ ///
+ /// Action required by the user (5)
+ ///
+ ActionRequired,
}
-}
\ No newline at end of file
+}
diff --git a/Common/Brokerages/DefaultBrokerageMessageHandler.cs b/Common/Brokerages/DefaultBrokerageMessageHandler.cs
index bd6291968eca..4a61d4ff5159 100644
--- a/Common/Brokerages/DefaultBrokerageMessageHandler.cs
+++ b/Common/Brokerages/DefaultBrokerageMessageHandler.cs
@@ -163,6 +163,11 @@ where exchange.IsOpenDuringBar(
_cancellationTokenSource.Cancel();
}
break;
+
+ case BrokerageMessageType.ActionRequired:
+ // not supported atm
+ _algorithm.SetRuntimeError(new Exception("Brokerage requires user action"), Messages.DefaultBrokerageMessageHandler.BrokerageDisconnectedShutDownContext);
+ break;
}
}
diff --git a/Engine/Setup/BrokerageSetupHandler.cs b/Engine/Setup/BrokerageSetupHandler.cs
index ad129ec4dc70..567e35e2b76c 100644
--- a/Engine/Setup/BrokerageSetupHandler.cs
+++ b/Engine/Setup/BrokerageSetupHandler.cs
@@ -135,6 +135,7 @@ public IBrokerage CreateBrokerage(AlgorithmNodePacket algorithmNodePacket, IAlgo
// initialize the correct brokerage using the resolved factory
var brokerage = _factory.CreateBrokerage(liveJob, uninitializedAlgorithm);
+ Composer.Instance.AddPart(brokerage);
return brokerage;
}