Issue #3069: NotFound exception if consumer is deleted when its queue is gone - Pulp

Send by e-mail

Issue #3069

NotFound exception if consumer is deleted when its queue is gone

Added by ttereshc almost 4 years ago. Updated about 2 years ago.

Status:

CLOSED - CURRENTRELEASE

Priority:

Normal

Assignee:

dalley

Category:

Sprint/Milestone:

Start date:

Due date:

Estimated time:

Severity:

2. Medium

Version:

Platform Release:

2.14.3

OS:

Triaged:

Yes

Groomed:

Sprint Candidate:

Yes

Tags:

Easy Fix, Pulp 2

Sprint:

Sprint 27

Quarter:

Description

Occasionally, if a user is deleting a large number of hosts, one may fail during the run and be retried. If a host is deleted but its qpid queue is already gone, the delete will fail. Instead, the delete should continue, since it's trying to delete something that isn't there.

no such queue: pulp.agent.6d89102a-c6d7-4d52-920a-f6811f4ddb17                                                
Traceback (most recent call last):                                                                            
  File "/usr/lib/python2.7/site-packages/django/core/handlers/base.py", line 112, in get_response             
    response = wrapped_callback(request, *callback_args, **callback_kwargs)                                   
  File "/usr/lib/python2.7/site-packages/django/views/generic/base.py", line 69, in view                      
    return self.dispatch(request, *args, **kwargs)                                                            
  File "/usr/lib/python2.7/site-packages/django/views/generic/base.py", line 87, in dispatch                  
    return handler(request, *args, **kwargs)                                                                  
  File "/usr/lib/python2.7/site-packages/pulp/server/webservices/views/decorators.py", line 241, in _auth_decorator                                               
    return _verify_auth(self, operation, super_user_only, method, *args, **kwargs)                            
  File "/usr/lib/python2.7/site-packages/pulp/server/webservices/views/decorators.py", line 195, in _verify_auth                                                  
    value = method(self, *args, **kwargs)                                                                     
  File "/usr/lib/python2.7/site-packages/pulp/server/webservices/views/consumers.py", line 258, in delete     
    response = manager.unregister(consumer_id)                                                                
  File "/usr/lib/python2.7/site-packages/pulp/server/managers/consumer/cud.py", line 115, in unregister       
    agent_consumer.unregister(consumer_id)                                                                    
  File "/usr/lib/python2.7/site-packages/pulp/server/managers/consumer/agent.py", line 56, in unregister      
    agent.consumer.unregister(context)                                                                        
  File "/usr/lib/python2.7/site-packages/pulp/server/agent/direct/pulpagent.py", line 125, in unregister      
    consumer.unregister()                                                                                     
  File "/usr/lib/python2.7/site-packages/gofer/rmi/stub.py", line 91, in __call__                             
    return self.send(request)                                                                                 
  File "/usr/lib/python2.7/site-packages/gofer/common.py", line 234, in sfn                                   
    return fn(*args, **kwargs)                                                                                
  File "/usr/lib/python2.7/site-packages/gofer/rmi/stub.py", line 133, in __send                              
    return self.__policy(request)                                                                             
  File "/usr/lib/python2.7/site-packages/gofer/common.py", line 273, in _fn                                   
    return fn(*args, **kwargs)                                                                                
  File "/usr/lib/python2.7/site-packages/gofer/rmi/policy.py", line 279, in __call__                          
    return trigger()                                                                                          
  File "/usr/lib/python2.7/site-packages/gofer/rmi/policy.py", line 370, in __call__                          
    return self._send()                                                                                       
  File "/usr/lib/python2.7/site-packages/gofer/rmi/policy.py", line 337, in _send                             
    data=self._policy.data)                                                                                   
  File "/usr/lib/python2.7/site-packages/gofer/messaging/adapter/model.py", line 39, in _fn                   
    return fn(*args, **keywords)                                                                              
  File "/usr/lib/python2.7/site-packages/gofer/messaging/adapter/model.py", line 848, in send                 
    self._impl.send(address, signed, ttl)                                                                     
  File "/usr/lib/python2.7/site-packages/gofer/messaging/adapter/qpid/reliability.py", line 38, in _fn        
    raise NotFound(*e.args)                                                                                   
NotFound: no such queue: pulp.agent.6d89102a-c6d7-4d52-920a-f6811f4ddb17