YunoHost/yunorunner
1
0
Fork 0
mirror of https://github.com/YunoHost/yunorunner.git synced 2024-09-03 20:05:52 +02:00
Code Issues Projects Releases Packages Wiki Activity

Add flag to not monitor bad quality apps, meant for unstable CI

Browse source
This commit is contained in:
Alexandre Aubin 2021-03-01 20:28:10 +01:00
parent 11b3f42652
commit 0ad5937ec4
1 changed files with 12 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
run.py
View file

@ -185,7 +185,7 @@ async def create_job(app_id, repo_url, job_comment=""):
@always_relaunch(sleep=60 * 5) @always_relaunch(sleep=60 * 5)
async def monitor_apps_lists(dont_monitor_git=False): async def monitor_apps_lists(dont_monitor_git=False, only_good_quality_apps=False):
"parse apps lists every hour or so to detect new apps" "parse apps lists every hour or so to detect new apps"
# only support github for now :( # only support github for now :(
@ -206,10 +206,16 @@ async def monitor_apps_lists(dont_monitor_git=False):
for app_id, app_data in data.items(): for app_id, app_data in data.items():
commit_sha = await get_master_commit_sha(app_data["git"]["url"]) commit_sha = await get_master_commit_sha(app_data["git"]["url"])
if app_data["state"] not in "working": if app_data["state"] != "working":
task_logger.debug(f"skip {app_id} because state is {app_data['state']}") task_logger.debug(f"skip {app_id} because state is {app_data['state']}")
continue continue
if only_good_quality_apps:
if app_data.get("level") in [None, "?"] or app_data["level"] <= 4:
task_logger.debug(f"skip {app_id} because app is not good quality")
continue
# already know, look to see if there is new commits # already know, look to see if there is new commits
if app_id in repos: if app_id in repos:
repo = repos[app_id] repo = repos[app_id]
@ -1111,7 +1117,8 @@ def format_frame(f):
return dict([(k, str(getattr(f, k))) for k in keys]) return dict([(k, str(getattr(f, k))) for k in keys])
def main(path_to_analyseCI, dont_monitor_apps_list=False, dont_monitor_git=False, no_monthly_jobs=False, port=4242, base_url="", debug=False): def main(path_to_analyseCI, dont_monitor_apps_list=False, dont_monitor_git=False, only_good_quality_apps=False, no_monthly_jobs=False, port=4242, base_url="", debug=False):
if not os.path.exists(path_to_analyseCI): if not os.path.exists(path_to_analyseCI):
print(f"Error: analyseCI script doesn't exist at '{path_to_analyseCI}'") print(f"Error: analyseCI script doesn't exist at '{path_to_analyseCI}'")
sys.exit(1) sys.exit(1)
@ -1126,7 +1133,8 @@ def main(path_to_analyseCI, dont_monitor_apps_list=False, dont_monitor_git=False
app.config.base_url = base_url app.config.base_url = base_url
if not dont_monitor_apps_list: if not dont_monitor_apps_list:
app.add_task(monitor_apps_lists(dont_monitor_git=dont_monitor_git)) app.add_task(monitor_apps_lists(dont_monitor_git=dont_monitor_git,
only_good_quality_apps=only_good_quality_apps))
if not no_monthly_jobs: if not no_monthly_jobs:
app.add_task(launch_monthly_job()) app.add_task(launch_monthly_job())