Long-running eventually leads to hbmqtt error

[kruton]

This scrolled out of my tmux buffer, but at the end I see this repeating:

The above exception was the direct cause of the following exception:                                                              
                                                                                                                                      
Traceback (most recent call last):                                                                                                   
  File "/usr/lib64/python3.9/asyncio/tasks.py", line 491, in wait_for                                                                                                  
    raise exceptions.TimeoutError() from exc                                                                          
asyncio.exceptions.TimeoutError                                                                                                                                              
2021-01-06 02:34:10,994   ERROR    root: Caught global exception:                                                                                                      
Traceback (most recent call last):                                                                                                                                           
  File "/home/kenny/.local/share/virtualenvs/petnet-feeder-service-TkeC7i61/lib/python3.9/site-packages/hbmqtt/mqtt/protocol/handler.py", line 237, in _handle_message_flow                      
    await self._handle_qos2_message_flow(app_message)                                                                                                                               
  File "/home/kenny/.local/share/virtualenvs/petnet-feeder-service-TkeC7i61/lib/python3.9/site-packages/hbmqtt/mqtt/protocol/handler.py", line 366, in _handle_qos2_message_flow                 
    await waiter                                                                                                                  
asyncio.exceptions.CancelledError                                                                                           
                                                                                                                          
During handling of the above exception, another exception occurred:                                                                   
                                                                                                                            
Traceback (most recent call last):                                                                                        
  File "/usr/lib64/python3.9/asyncio/tasks.py", line 489, in wait_for                                                               
    fut.result()                                                                                                          
asyncio.exceptions.CancelledError                                                                                                                                            
                                                                                                                            
The above exception was the direct cause of the following exception:                                                      
                                                                                                                                                                             
Traceback (most recent call last):                                                                                                
  File "/usr/lib64/python3.9/asyncio/tasks.py", line 491, in wait_for                                                                 
    raise exceptions.TimeoutError() from exc                                                                                         
asyncio.exceptions.TimeoutError                                                                                                                                        
2021-01-06 02:34:10,994   ERROR    root: Caught global exception:                                                                                                            
Traceback (most recent call last):                                                                                                                                                  
  File "/home/kenny/.local/share/virtualenvs/petnet-feeder-service-TkeC7i61/lib/python3.9/site-packages/hbmqtt/mqtt/protocol/handler.py", line 237, in _handle_message_flow  
    await self._handle_qos2_message_flow(app_message)                                                                                                                               
  File "/home/kenny/.local/share/virtualenvs/petnet-feeder-service-TkeC7i61/lib/python3.9/site-packages/hbmqtt/mqtt/protocol/handler.py", line 366, in _handle_qos2_message_flow                 
    await waiter                                                   
asyncio.exceptions.CancelledError                                                                                         
                                                                                                                                  
During handling of the above exception, another exception occurred:                                                         
                                                                                                                          
Traceback (most recent call last):                                                                                                    
  File "/usr/lib64/python3.9/asyncio/tasks.py", line 489, in wait_for                                                       
    fut.result()                                              
asyncio.exceptions.CancelledError                                                                                                   
                                                                                                                                  
The above exception was the direct cause of the following exception:                                                                                                                             
                                                                                                                                    
Traceback (most recent call last):                                                                                                    
  File "/usr/lib64/python3.9/asyncio/tasks.py", line 491, in wait_for                                                                                                                            
    raise exceptions.TimeoutError() from exc                       
asyncio.exceptions.TimeoutError   

[mbillow]

This should probably be filed in the hbmqtt fork. From the trace it, it looks like the call to self._handle_qos2_message_flow(app_message) is being canceled by asyncio while await waiter is waiting.