|
@@ -43,11 +43,8 @@ class MonitoringCoordinator:
|
|
# Initialize copy trading monitor if available
|
|
# Initialize copy trading monitor if available
|
|
if COPY_TRADING_AVAILABLE:
|
|
if COPY_TRADING_AVAILABLE:
|
|
try:
|
|
try:
|
|
- # DISABLE: Still causing blocking issues despite timeouts
|
|
|
|
- # self.copy_trading_monitor = CopyTradingMonitor(hl_client, notification_manager)
|
|
|
|
- # logger.info("✅ Copy trading monitor initialized (non-blocking version)")
|
|
|
|
- self.copy_trading_monitor = None
|
|
|
|
- logger.info("🚫 Copy trading monitor disabled - still causing blocking issues")
|
|
|
|
|
|
+ self.copy_trading_monitor = CopyTradingMonitor(hl_client, notification_manager)
|
|
|
|
+ logger.info("✅ Copy trading monitor initialized (with non-blocking state manager)")
|
|
except Exception as e:
|
|
except Exception as e:
|
|
logger.error(f"❌ Failed to initialize copy trading monitor: {e}")
|
|
logger.error(f"❌ Failed to initialize copy trading monitor: {e}")
|
|
self.copy_trading_monitor = None
|
|
self.copy_trading_monitor = None
|
|
@@ -83,7 +80,7 @@ class MonitoringCoordinator:
|
|
if self.copy_trading_monitor and hasattr(self.copy_trading_monitor, 'enabled') and self.copy_trading_monitor.enabled:
|
|
if self.copy_trading_monitor and hasattr(self.copy_trading_monitor, 'enabled') and self.copy_trading_monitor.enabled:
|
|
try:
|
|
try:
|
|
asyncio.create_task(self.copy_trading_monitor.start_monitoring())
|
|
asyncio.create_task(self.copy_trading_monitor.start_monitoring())
|
|
- logger.info("🔄 Copy trading monitor started (non-blocking)")
|
|
|
|
|
|
+ logger.info("🔄 Copy trading monitor started (with non-blocking state manager)")
|
|
except Exception as e:
|
|
except Exception as e:
|
|
logger.error(f"❌ Failed to start copy trading monitor: {e}")
|
|
logger.error(f"❌ Failed to start copy trading monitor: {e}")
|
|
|
|
|