mirror of
				https://github.com/zulip/zulip.git
				synced 2025-11-04 05:53:43 +00:00 
			
		
		
		
	check-rabbitmq-consumers: Go back to hardcoding for now.
This should fix the production test suite in Travis CI, so that we can debug what's broken here offline.
This commit is contained in:
		@@ -37,12 +37,26 @@ consumers = defaultdict(int) # type: Dict[str, int]
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
sys.path.append(os.path.join(os.path.dirname(os.path.dirname(os.path.dirname(__file__)))))
 | 
					sys.path.append(os.path.join(os.path.dirname(os.path.dirname(os.path.dirname(__file__)))))
 | 
				
			||||||
from scripts.lib.zulip_tools import su_to_zulip
 | 
					from scripts.lib.zulip_tools import su_to_zulip
 | 
				
			||||||
queues = subprocess.check_output([os.path.abspath('./scripts/lib/queue_workers.py'),
 | 
					queues = {
 | 
				
			||||||
                                  '--queue-type=consumer'],
 | 
					    'digest_emails',
 | 
				
			||||||
                                 universal_newlines=True,
 | 
					    'email_mirror',
 | 
				
			||||||
                                 preexec_fn=su_to_zulip)
 | 
					    'embed_links',
 | 
				
			||||||
 | 
					    'error_reports',
 | 
				
			||||||
 | 
					    'feedback_messages',
 | 
				
			||||||
 | 
					    'invites',
 | 
				
			||||||
 | 
					    'message_sender',
 | 
				
			||||||
 | 
					    'missedmessage_emails',
 | 
				
			||||||
 | 
					    'missedmessage_mobile_notifications',
 | 
				
			||||||
 | 
					    'notify_tornado',
 | 
				
			||||||
 | 
					    'signups',
 | 
				
			||||||
 | 
					    'slow_queries',
 | 
				
			||||||
 | 
					    'tornado_return',
 | 
				
			||||||
 | 
					    'user_activity'
 | 
				
			||||||
 | 
					    'user_activity_interval',
 | 
				
			||||||
 | 
					    'user_presence',
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
for queue_name in queues.split("\n"):
 | 
					for queue_name in queues:
 | 
				
			||||||
    queue_name = queue_name.strip()
 | 
					    queue_name = queue_name.strip()
 | 
				
			||||||
    consumers[queue_name] = 0
 | 
					    consumers[queue_name] = 0
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user