Update data_manager.py

data_manager.py

@@ -691,6 +691,15 @@ class DataManager:
                 await asyncio.sleep(1)
         
         print(f"✅ [المنتج] اكتمل تدفق بيانات OHLCV. تم إرسال {total_successful} عملة للمعالجة.")
+        
+        # 🔴 --- START OF CHANGE --- 🔴
+        # (إرسال إشارة "None" لإنهاء المستهلك)
+        try:
+            await queue.put(None)
+            print("      📬 [المنتج] تم إرسال إشارة الإنهاء (None) إلى الطابور.")
+        except Exception as q_err:
+            print(f"      ❌ [المنتج] فشل إرسال إشارة الإنهاء (None) للطابور: {q_err}")
+        # 🔴 --- END OF CHANGE --- 🔴
     # 🔴 --- نهاية التعديل الجوهري --- 🔴
 
 
@@ -893,4 +902,4 @@ class DataManager:
                 'source': 'whale_analysis'
             }
 
-print("✅ DataManager loaded - Fixed get_latest_price_async Function")
+print("✅ DataManager loaded - (FIXED: Added stream_ohlcv_data 'None' terminator)")