Spaces:
Paused
Paused
Auto-Fix by Architect: Auto-Fix: ASSIGN_ARCHITECT | Quant Silence indicates potential code bug in analysis module, requiring Python fix to resolve. by Agent Architect
Browse files- ml_engine/processor.py +7 -2
ml_engine/processor.py
CHANGED
|
@@ -393,6 +393,7 @@ class MLProcessor:
|
|
| 393 |
return decision
|
| 394 |
except Exception as e:
|
| 395 |
print(f"❌ [Processor] Oracle consultation error: {e}")
|
|
|
|
| 396 |
return {'action': 'WAIT', 'reason': f'Oracle error: {str(e)}'}
|
| 397 |
return {'action': 'WAIT', 'reason': 'Oracle Engine Missing'}
|
| 398 |
|
|
@@ -418,6 +419,7 @@ class MLProcessor:
|
|
| 418 |
return await self.sniper.check_entry_signal_async(ohlcv_1m_data, order_book_data)
|
| 419 |
except Exception as e:
|
| 420 |
print(f"❌ [Processor] Sniper entry check error: {e}")
|
|
|
|
| 421 |
return {'signal': 'WAIT', 'reason': f'Sniper error: {str(e)}'}
|
| 422 |
|
| 423 |
return {'signal': 'WAIT', 'reason': 'Sniper Engine Missing'}
|
|
@@ -451,7 +453,7 @@ class MLProcessor:
|
|
| 451 |
# 1. Hydra Execution (Conditional)
|
| 452 |
# -----------------------------------------------
|
| 453 |
hydra_result = {'action': 'HOLD', 'reason': 'Disabled', 'probs': {}}
|
| 454 |
-
if self.guardian_hydra and self.guardian_hydra
|
| 455 |
try:
|
| 456 |
hydra_result = self.guardian_hydra.analyze_position(symbol, ohlcv_1m, ohlcv_5m, ohlcv_15m, trade_context)
|
| 457 |
h_probs = hydra_result.get('probs', {})
|
|
@@ -482,13 +484,14 @@ class MLProcessor:
|
|
| 482 |
hydra_result['action'] = 'HOLD' # Too early
|
| 483 |
except Exception as e:
|
| 484 |
print(f"⚠️ [Processor] Hydra analysis error: {e}")
|
|
|
|
| 485 |
hydra_result = {'action': 'HOLD', 'reason': f'Hydra error: {str(e)}', 'probs': {}}
|
| 486 |
|
| 487 |
# -----------------------------------------------
|
| 488 |
# 2. Legacy Execution (Fixed Thresholds)
|
| 489 |
# -----------------------------------------------
|
| 490 |
legacy_result = {'action': 'HOLD', 'reason': 'Disabled', 'scores': {}}
|
| 491 |
-
if self.guardian_legacy and self.guardian_legacy
|
| 492 |
try:
|
| 493 |
self.guardian_legacy.configure_thresholds(
|
| 494 |
v2_panic=0.98,
|
|
@@ -504,6 +507,7 @@ class MLProcessor:
|
|
| 504 |
)
|
| 505 |
except Exception as e:
|
| 506 |
print(f"⚠️ [Processor] Legacy guardian analysis error: {e}")
|
|
|
|
| 507 |
legacy_result = {'action': 'HOLD', 'reason': f'Legacy error: {str(e)}', 'scores': {}}
|
| 508 |
|
| 509 |
# -----------------------------------------------
|
|
@@ -548,5 +552,6 @@ class MLProcessor:
|
|
| 548 |
return self.mc_analyzer.run_advanced_simulation([c[4] for c in ohlcv])
|
| 549 |
except Exception as e:
|
| 550 |
print(f"⚠️ [Processor] Advanced MC error for {symbol}: {e}")
|
|
|
|
| 551 |
pass
|
| 552 |
return 0.0
|
|
|
|
| 393 |
return decision
|
| 394 |
except Exception as e:
|
| 395 |
print(f"❌ [Processor] Oracle consultation error: {e}")
|
| 396 |
+
traceback.print_exc()
|
| 397 |
return {'action': 'WAIT', 'reason': f'Oracle error: {str(e)}'}
|
| 398 |
return {'action': 'WAIT', 'reason': 'Oracle Engine Missing'}
|
| 399 |
|
|
|
|
| 419 |
return await self.sniper.check_entry_signal_async(ohlcv_1m_data, order_book_data)
|
| 420 |
except Exception as e:
|
| 421 |
print(f"❌ [Processor] Sniper entry check error: {e}")
|
| 422 |
+
traceback.print_exc()
|
| 423 |
return {'signal': 'WAIT', 'reason': f'Sniper error: {str(e)}'}
|
| 424 |
|
| 425 |
return {'signal': 'WAIT', 'reason': 'Sniper Engine Missing'}
|
|
|
|
| 453 |
# 1. Hydra Execution (Conditional)
|
| 454 |
# -----------------------------------------------
|
| 455 |
hydra_result = {'action': 'HOLD', 'reason': 'Disabled', 'probs': {}}
|
| 456 |
+
if self.guardian_hydra and getattr(self.guardian_hydra, 'initialized', False):
|
| 457 |
try:
|
| 458 |
hydra_result = self.guardian_hydra.analyze_position(symbol, ohlcv_1m, ohlcv_5m, ohlcv_15m, trade_context)
|
| 459 |
h_probs = hydra_result.get('probs', {})
|
|
|
|
| 484 |
hydra_result['action'] = 'HOLD' # Too early
|
| 485 |
except Exception as e:
|
| 486 |
print(f"⚠️ [Processor] Hydra analysis error: {e}")
|
| 487 |
+
traceback.print_exc()
|
| 488 |
hydra_result = {'action': 'HOLD', 'reason': f'Hydra error: {str(e)}', 'probs': {}}
|
| 489 |
|
| 490 |
# -----------------------------------------------
|
| 491 |
# 2. Legacy Execution (Fixed Thresholds)
|
| 492 |
# -----------------------------------------------
|
| 493 |
legacy_result = {'action': 'HOLD', 'reason': 'Disabled', 'scores': {}}
|
| 494 |
+
if self.guardian_legacy and getattr(self.guardian_legacy, 'initialized', False):
|
| 495 |
try:
|
| 496 |
self.guardian_legacy.configure_thresholds(
|
| 497 |
v2_panic=0.98,
|
|
|
|
| 507 |
)
|
| 508 |
except Exception as e:
|
| 509 |
print(f"⚠️ [Processor] Legacy guardian analysis error: {e}")
|
| 510 |
+
traceback.print_exc()
|
| 511 |
legacy_result = {'action': 'HOLD', 'reason': f'Legacy error: {str(e)}', 'scores': {}}
|
| 512 |
|
| 513 |
# -----------------------------------------------
|
|
|
|
| 552 |
return self.mc_analyzer.run_advanced_simulation([c[4] for c in ohlcv])
|
| 553 |
except Exception as e:
|
| 554 |
print(f"⚠️ [Processor] Advanced MC error for {symbol}: {e}")
|
| 555 |
+
traceback.print_exc()
|
| 556 |
pass
|
| 557 |
return 0.0
|