Dynamic tokens in websocket

tukkan

I a trying to update the tokens dynamically but its not working. Can you please let me know the problem with following code?

#create KiteTicker object
kws = KiteTicker(key_secret[0], kite.access_token)
tokens = tokenLookup(instrument_df, tickers)

def on_ticks(ws,ticks):
#renkoOperation(ticks)
#stopLoss(ticks)
print(ticks)

def on_connect(ws,response):
ws.subscribe(tokens)
ws.set_mode(ws.MODE_LTP,tokens)

def on_close(ws, code, reason):
# On connection close stop the main loop
# Reconnection will not happen after executing `ws.stop()`
ws.stop()

# Assign the callbacks.
kws.on_ticks = on_ticks
kws.on_connect = on_connect
kws.on_close = on_close


# Infinite loop on the main thread. Nothing after this will run.
# You have to use the pre-defined callbacks to manage subscriptions.
kws.connect(threaded=True) #multithreaded application
time.sleep(3)

positions_data = {}
subscribed_tokens = [] # Initialize with an empty list to track subscribed tokens

positions = kite.positions()["net"]
updated_positions = {}
for position in positions:
symbol = position["tradingsymbol"]
updated_positions[symbol] = {
"instrument_token": position["instrument_token"],
"quantity": position["quantity"],
"average_price": position["average_price"],
"pnl": 0, # Will be updated dynamically
}

# Update global positions_data
positions_data = updated_positions
logging.info(f"Updated positions: {positions_data}")

# Ensure required tokens remain subscribed
required_tokens = [instrumentLookup(instrument_df, "NIFTY 50")] # Add required persistent tokens here
new_tokens = [position["instrument_token"] for position in positions_data.values()]
tokens_to_subscribe = list(set(required_tokens + new_tokens) - set(subscribed_tokens))
tokens = tokens_to_subscribe
tokens = [str(token) for token in tokens]


kws.subscribe(tokens)