removed dynamic ranking for now - testing failed because of yfinance throttling

Author: yeonholee50

ranking_client.py

@@ -75,8 +75,8 @@ def process_ticker(ticker, mongo_client):
             time.sleep(10)
       while historical_data is None:
          try:
-            period = dynamic_period_selector(ticker)
-            historical_data = get_data(ticker, period)
+            
+            historical_data = get_data(ticker)
          except Exception as fetch_error:
             logging.warning(f"Error fetching historical data for {ticker}. Retrying... {fetch_error}")
             time.sleep(10)

strategies/talib_indicators.py

@@ -103,9 +103,10 @@ def MAMA_indicator(ticker, data):
     close_prices = data['Close'].values
 
     # Validate enough data
+    """
     if len(close_prices) < 32:  # Minimum length required by MAMA
         raise ValueError("Not enough data to compute MAMA.")
-
+    """
     # Calculate MAMA and FAMA
     try:
         mama, fama = ta.MAMA(close_prices, fastlimit=0.5, slowlimit=0.05)
@@ -136,11 +137,11 @@ def MAVP_indicator(ticker, data):
     """
 
     close_prices = data['Close'].values
-
+    """
     # Validate enough data
     if len(close_prices) < 30:  # Ensure enough data for MAVP calculation
         raise ValueError("Not enough data to compute MAVP.")
-
+    """
     # Define variable periods as a NumPy array
     variable_periods = np.full(len(close_prices), 30, dtype=np.float64)
     # Calculate MAVP

testing_client.py

@@ -41,4 +41,7 @@ def test_strategies():
 
 
 if __name__ == "__main__":  
-   test_strategies()
+   print(get_latest_price('VRTX'))
+   """
+   test_strategies()
+   """

trading_client.py

@@ -114,7 +114,8 @@ def main():
                     early_hour_first_iteration = False
                     post_hour_first_iteration = True
             account = trading_client.get_account()
-            
+            qqq_latest = get_latest_price('QQQ')
+            spy_latest = get_latest_price('SPY')
             buy_heap = []
             for ticker in ndaq_tickers:
                 decisions_and_quantities = []
@@ -134,13 +135,15 @@ def main():
                     we update instead of insert
                     """
                     portfolio_collection.update_one({"name" : "portfolio_percentage"}, {"$set": {"portfolio_percentage": (portfolio_value-50000)/50000}})
-                    portfolio_collection.update_one({"name" : "ndaq_percentage"}, {"$set": {"portfolio_percentage": (get_latest_price('QQQ')-503.17)/503.17}})
-                    portfolio_collection.update_one({"name" : "spy_percentage"}, {"$set": {"portfolio_percentage": (get_latest_price('SPY')-590.50)/590.50}})
+                    portfolio_collection.update_one({"name" : "ndaq_percentage"}, {"$set": {"portfolio_percentage": (qqq_latest-503.17)/503.17}})
+                    portfolio_collection.update_one({"name" : "spy_percentage"}, {"$set": {"portfolio_percentage": (spy_latest-590.50)/590.50}})
+                    
                     historical_data = None
                     while historical_data is None:
                         try:
-                            period = dynamic_period_selector(ticker)
-                            historical_data = get_data(ticker, period)
+                            
+
+                            historical_data = get_data(ticker)
                         except:
                             print(f"Error fetching data for {ticker}. Retrying...")
 
@@ -151,6 +154,7 @@ def main():
                             current_price = get_latest_price(ticker)
                         except:
                             print(f"Error fetching price for {ticker}. Retrying...")
+                            time.sleep(10)
                     print(f"Current price of {ticker}: {current_price}")
 
                     asset_info = asset_collection.find_one({'symbol': ticker})
@@ -199,6 +203,7 @@ def main():
                     print(f"buy_coeff: {buy_coeff}, quantity: {quantity}, ticker: {ticker}")
 
                     order = place_order(trading_client, ticker, OrderSide.BUY, qty=quantity, mongo_url=mongo_url)  # Place order using helper
+                    
                     logging.info(f"Executed BUY order for {ticker}: {order}")
 
                     trading_client = TradingClient(API_KEY, API_SECRET)