Multiple and alternating messages.

[gck303]

I am getting strange repeated messages which are alternating on/off. Not quite sure what is going on.

This is the output from whening running the script in the foreground.

Any ideas?

When I restart the script the problem goes.

Device dehumidifier is too busy to take request to be set as on Device dehumidifier is too busy to take request to be set as off Device dehumidifier is too busy to take request to be set as on Device dehumidifier is too busy to take request to be set as off Device dehumidifier is too busy to take request to be set as on Device dehumidifier is too busy to take request to be set as off Device dehumidifier is too busy to take request to be set as on Device dehumidifier is too busy to take request to be set as off Device dehumidifier is too busy to take request to be set as on Device dehumidifier is too busy to take request to be set as off Device dehumidifier is too busy to take request to be set as on Device dehumidifier is too busy to take request to be set as off Device dehumidifier is too busy to take request to be set as on Device dehumidifier is too busy to take request to be set as off Device dehumidifier is too busy to take request to be set as on Device dehumidifier is too busy to take request to be set as off Device dehumidifier is too busy to take request to be set as on Device dehumidifier is too busy to take request to be set as off Device dehumidifier is too busy to take request to be set as on Device dehumidifier is too busy to take request to be set as off Device dehumidifier is too busy to take request to be set as on Device dehumidifier is too busy to take request to be set as off Device dehumidifier is too busy to take request to be set as on

[flavio-fernandes]

This means that the kasa device is being asked to change state too often and the code is explicitly throttling it.

mqtt2kasa/mqtt2kasa/main.py

Lines 104 to 109 in 17096b0

	except asyncio.queues.QueueFull:
	logger.warning(
	f"Device {name} is too busy to take request to be set as "
	f"{kasa.state_name(new_state)}"
	)
	return

Any chance that is happening in your environment?

The queue size is 4:

mqtt2kasa/mqtt2kasa/kasa_wrapper.py

Line 30 in 17096b0

self.recv_q = asyncio.Queue(maxsize=4)

Which means, the Kasa device may be getting bombarded with requests and that seems suspicious.

Not a bug; functioning as implemented. :)