mirror of
https://github.com/odoo/runbot.git
synced 2025-04-07 10:50:52 +07:00
2cad0542f4
Before the commit the build ir_logging was sent from the build instance to the main runbot ir.logging table. As the number of runbot hosts increases, it introduce a lot of concurrency. e.g.: 80 hosts with 8 builds means 640 instances trying to insert records in the ir.logging table. With this commit, a special database is used on the builder host in order to receive ir.logging's from the build instances. Regulary, the table is emptied by the builder and the logs are inserted in the runbot leader ir.logging table.
56 lines
2.6 KiB
Python
56 lines
2.6 KiB
Python
# -*- coding: utf-8 -*-
|
|
from unittest.mock import patch
|
|
from .common import RunbotCase
|
|
|
|
|
|
class SleepException(Exception):
|
|
...
|
|
|
|
|
|
def sleep(time):
|
|
raise SleepException()
|
|
|
|
|
|
class TestCron(RunbotCase):
|
|
|
|
def setUp(self):
|
|
super(TestCron, self).setUp()
|
|
self.start_patcher('list_local_dbs_patcher', 'odoo.addons.runbot.models.host.list_local_dbs', ['runbot_logs'])
|
|
self.start_patcher('_get_cron_period', 'odoo.addons.runbot.models.runbot.Runbot._get_cron_period', 2)
|
|
|
|
@patch('time.sleep', side_effect=sleep)
|
|
@patch('odoo.addons.runbot.models.repo.Repo._update_batches')
|
|
def test_cron_schedule(self, mock_update_batches, *args):
|
|
""" test that cron_fetch_and_schedule do its work """
|
|
self.env['ir.config_parameter'].sudo().set_param('runbot.runbot_update_frequency', 1)
|
|
self.env['ir.config_parameter'].sudo().set_param('runbot.runbot_do_fetch', True)
|
|
self.env['runbot.repo'].search([('id', '!=', self.repo_server.id)]).write({'mode': 'disabled'}) # disable all other existing repo than repo_server
|
|
try:
|
|
self.Runbot._cron()
|
|
except SleepException:
|
|
pass # sleep raises an exception to avoid to stay stuck in loop
|
|
mock_update_batches.assert_called()
|
|
|
|
@patch('time.sleep', side_effect=sleep)
|
|
@patch('odoo.addons.runbot.models.host.Host._docker_build')
|
|
@patch('odoo.addons.runbot.models.host.Host._bootstrap')
|
|
@patch('odoo.addons.runbot.models.runbot.Runbot._scheduler')
|
|
def test_cron_build(self, mock_scheduler, mock_host_bootstrap, mock_host_docker_build, *args):
|
|
""" test that cron_fetch_and_build do its work """
|
|
hostname = 'cronhost.runbot.com'
|
|
self.patchers['hostname_patcher'].return_value = hostname
|
|
self.env['ir.config_parameter'].sudo().set_param('runbot.runbot_update_frequency', 1)
|
|
self.env['ir.config_parameter'].sudo().set_param('runbot.runbot_do_schedule', True)
|
|
self.env['runbot.repo'].search([('id', '!=', self.repo_server.id)]).write({'mode': 'disabled'}) # disable all other existing repo than repo_server
|
|
|
|
try:
|
|
self.Runbot._cron()
|
|
except SleepException:
|
|
pass # sleep raises an exception to avoid to stay stuck in loop
|
|
mock_scheduler.assert_called()
|
|
mock_host_bootstrap.assert_called()
|
|
mock_host_docker_build.assert_called()
|
|
host = self.env['runbot.host'].search([('name', '=', hostname)])
|
|
self.assertTrue(host, 'A new host should have been created')
|
|
# self.assertGreater(host.psql_conn_count, 0, 'A least one connection should exist on the current psql batch')
|