added minimal excpetion handling to communicator.py
	
		
			
	
		
	
	
		
	
		
			All checks were successful
		
		
	
	
		
			
				
	
				continuous-integration/drone/push Build is passing
				
			
		
		
	
	
				
					
				
			
		
			All checks were successful
		
		
	
	continuous-integration/drone/push Build is passing
				
			This commit is contained in:
		@@ -43,11 +43,14 @@ class Communicator:
 | 
				
			|||||||
        Get the list of available consumer from the current primary consumer.
 | 
					        Get the list of available consumer from the current primary consumer.
 | 
				
			||||||
        :return:
 | 
					        :return:
 | 
				
			||||||
        """
 | 
					        """
 | 
				
			||||||
 | 
					        try:
 | 
				
			||||||
            currentconsumer = self.currenctconsumer
 | 
					            currentconsumer = self.currenctconsumer
 | 
				
			||||||
            response = requests.get(f'http://{currentconsumer}/consumer')
 | 
					            response = requests.get(f'http://{currentconsumer}/consumer')
 | 
				
			||||||
            json = response.json()
 | 
					            json = response.json()
 | 
				
			||||||
            LOGGER.debug(f"List of currently available consumers: {json}")
 | 
					            LOGGER.debug(f"List of currently available consumers: {json}")
 | 
				
			||||||
            return json
 | 
					            return json
 | 
				
			||||||
 | 
					        except Exception:
 | 
				
			||||||
 | 
					            return []
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    def isconsumeravailable(self) -> bool:
 | 
					    def isconsumeravailable(self) -> bool:
 | 
				
			||||||
        """
 | 
					        """
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user