mirror of
https://pagure.io/fm-orchestrator.git
synced 2026-05-11 18:37:25 +08:00
f24cd4222f
Please note that this patch does not change the use of database session in MBS. So, in the frontend, the database session is still managed by Flask-SQLAlchemy, that is the db.session. And the backend, running event handlers, has its own database session created from SQLAclehmy session API directly. This patch aims to reduce the number of scoped_session created when call original function make_db_session. For technical detailed information, please refer to SQLAlchemy documentation Contextual/Thread-local Sessions. As a result, a global scoped_session is accessible from the code running inside backend, both the event handlers and functions called from handlers. The library code shared by frontend and backend, like resolvers, has no change. Similarly, db.session is only used to recreate database for every test. Signed-off-by: Chenxiong Qi <cqi@redhat.com>
95 lines
3.2 KiB
Python
95 lines
3.2 KiB
Python
# -*- coding: utf-8 -*-
|
|
# SPDX-License-Identifier: MIT
|
|
from module_build_service import conf, log
|
|
from module_build_service.builder.KojiModuleBuilder import KojiModuleBuilder
|
|
from module_build_service.db_session import db_session
|
|
from module_build_service.models import ModuleBuild, BUILD_STATES
|
|
|
|
|
|
def get_corresponding_module_build(nvr):
|
|
"""Find corresponding module build from database and return
|
|
|
|
:param str nvr: module build NVR. This is the subject_identifier included
|
|
inside ``greenwave.decision.update`` message.
|
|
:return: the corresponding module build object. For whatever the reason,
|
|
if the original module build id cannot be found from the Koji build of
|
|
``nvr``, None will be returned.
|
|
:rtype: :class:`ModuleBuild` or None
|
|
"""
|
|
koji_session = KojiModuleBuilder.get_session(conf, login=False)
|
|
build_info = koji_session.getBuild(nvr)
|
|
if build_info is None:
|
|
return None
|
|
|
|
try:
|
|
module_build_id = build_info["extra"]["typeinfo"]["module"]["module_build_service_id"]
|
|
except KeyError:
|
|
# If any of the keys is not present, the NVR is not the one for
|
|
# handling Greenwave event.
|
|
return None
|
|
|
|
return ModuleBuild.get_by_id(db_session, module_build_id)
|
|
|
|
|
|
def decision_update(config, msg):
|
|
"""Move module build to ready or failed according to Greenwave result
|
|
|
|
:param config: the config object returned from function :func:`init_config`,
|
|
which is loaded from configuration file.
|
|
:type config: :class:`Config`
|
|
:param msg: the message object representing a message received from topic
|
|
``greenwave.decision.update``.
|
|
:type msg: :class:`GreenwaveDecisionUpdate`
|
|
"""
|
|
if not config.greenwave_decision_context:
|
|
log.debug(
|
|
"Skip Greenwave message %s as MBS does not have GREENWAVE_DECISION_CONTEXT "
|
|
"configured",
|
|
msg.msg_id,
|
|
)
|
|
return
|
|
|
|
if msg.decision_context != config.greenwave_decision_context:
|
|
log.debug(
|
|
"Skip Greenwave message %s as MBS only handles messages with the "
|
|
'decision context "%s"',
|
|
msg.msg_id,
|
|
config.greenwave_decision_context,
|
|
)
|
|
return
|
|
|
|
module_build_nvr = msg.subject_identifier
|
|
|
|
if not msg.policies_satisfied:
|
|
log.debug(
|
|
"Skip to handle module build %s because it has not satisfied Greenwave policies.",
|
|
module_build_nvr,
|
|
)
|
|
return
|
|
|
|
build = get_corresponding_module_build(module_build_nvr)
|
|
|
|
if build is None:
|
|
log.debug(
|
|
"No corresponding module build of subject_identifier %s is found.", module_build_nvr)
|
|
return
|
|
|
|
if build.state == BUILD_STATES["done"]:
|
|
build.transition(
|
|
db_session,
|
|
conf,
|
|
BUILD_STATES["ready"],
|
|
state_reason="Module build {} has satisfied Greenwave policies.".format(
|
|
module_build_nvr
|
|
),
|
|
)
|
|
else:
|
|
log.warning(
|
|
"Module build %s is not in done state but Greenwave tells "
|
|
"it passes tests in decision context %s",
|
|
module_build_nvr,
|
|
msg.decision_context,
|
|
)
|
|
|
|
db_session.commit()
|