Hi,
I have a simple sync consumer which receives websocket messages from the client, and each time, It passes a message to a worker channel to process it.
A LOT of the messages are just simply lost and not processed.
I have a print ("sent") whenever a message is sent to the worker channel.
I have another print("received") statement at the beginning of worker's method.
If I send tasks to the worker more frequently that every 2-3 seconds, the worker simply just ignores them. I see the "sent" in main stdout, but not received in the worker's stdout
I have to wait 2-3 seconds and send another message to see "received" statement in stdout
That is so strange and disappointing. I am debugging on Windows Pycharm, and running the worker process correctly I guess
I appreciate any insights