modules/fm-orchestrator
1
0
Fork 0
mirror of https://pagure.io/fm-orchestrator.git synced 2026-04-01 18:01:40 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Don't overwrite the state parameter in _nudge_module_builds_in_state

Browse Source
This commit is contained in:
mprahl
2018-12-18 17:10:00 -05:00
parent fec1a8be92
commit e237676c7e
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
module_build_service/scheduler/producer.py
View File

@@ -194,15 +194,15 @@ class MBSProducer(PollingProducer):
log.info(' * {0} components in batch {1}'
.format(n, i))
def _nudge_module_builds_in_state(self, session, state, older_than_minutes):
def _nudge_module_builds_in_state(self, session, state_name, older_than_minutes):
"""
Finds all the module builds in the `state` with `time_modified` older
than `older_than_minutes` and adds fake MBSModule message to the
work queue.
"""
log.info('Looking for module builds stuck in the %s state', state)
builds = models.ModuleBuild.by_state(session, state)
log.info(' %r module builds in the %s state...', len(builds), state)
log.info('Looking for module builds stuck in the %s state', state_name)
builds = models.ModuleBuild.by_state(session, state_name)
log.info(' %r module builds in the %s state...', len(builds), state_name)
now = datetime.utcnow()
time_modified_threshold = timedelta(minutes=older_than_minutes)
for build in builds:
@@ -216,7 +216,7 @@ class MBSProducer(PollingProducer):
session.commit()
# Fake a message to kickstart the build anew in the consumer
state = module_build_service.models.BUILD_STATES[state]
state = module_build_service.models.BUILD_STATES[state_name]
msg = module_build_service.messaging.MBSModule(
'nudge_module_builds_fake_message', build.id, state)
log.info(" Scheduling faked event %r" % msg)