diff options
Diffstat (limited to 'lib/python2.7/site-packages/buildbot-0.8.8-py2.7.egg/buildbot/steps/trigger.py')
| -rw-r--r-- | lib/python2.7/site-packages/buildbot-0.8.8-py2.7.egg/buildbot/steps/trigger.py | 224 |
1 files changed, 0 insertions, 224 deletions
diff --git a/lib/python2.7/site-packages/buildbot-0.8.8-py2.7.egg/buildbot/steps/trigger.py b/lib/python2.7/site-packages/buildbot-0.8.8-py2.7.egg/buildbot/steps/trigger.py deleted file mode 100644 index 11f6078a..00000000 --- a/lib/python2.7/site-packages/buildbot-0.8.8-py2.7.egg/buildbot/steps/trigger.py +++ /dev/null @@ -1,224 +0,0 @@ -# This file is part of Buildbot. Buildbot is free software: you can -# redistribute it and/or modify it under the terms of the GNU General Public -# License as published by the Free Software Foundation, version 2. -# -# This program is distributed in the hope that it will be useful, but WITHOUT -# ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS -# FOR A PARTICULAR PURPOSE. See the GNU General Public License for more -# details. -# -# You should have received a copy of the GNU General Public License along with -# this program; if not, write to the Free Software Foundation, Inc., 51 -# Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. -# -# Copyright Buildbot Team Members - -from buildbot.interfaces import ITriggerableScheduler -from buildbot.process.buildstep import LoggingBuildStep, SUCCESS, FAILURE, EXCEPTION -from buildbot.process.properties import Properties, Property -from twisted.python import log -from twisted.internet import defer -from buildbot import config - -class Trigger(LoggingBuildStep): - name = "trigger" - - renderables = [ 'set_properties', 'schedulerNames', 'sourceStamps', - 'updateSourceStamp', 'alwaysUseLatest' ] - - flunkOnFailure = True - - def __init__(self, schedulerNames=[], sourceStamp = None, sourceStamps = None, - updateSourceStamp=None, alwaysUseLatest=False, - waitForFinish=False, set_properties={}, - copy_properties=[], noWait=[], **kwargs): - if not schedulerNames: - config.error( - "You must specify a scheduler to trigger") - if (sourceStamp or sourceStamps) and (updateSourceStamp is not None): - config.error( - "You can't specify both sourceStamps and updateSourceStamp") - if (sourceStamp or sourceStamps) and alwaysUseLatest: - config.error( - "You can't specify both sourceStamps and alwaysUseLatest") - if alwaysUseLatest and (updateSourceStamp is not None): - config.error( - "You can't specify both alwaysUseLatest and updateSourceStamp" - ) - self.schedulerNames = schedulerNames - self.noWait = noWait - self.sourceStamps = sourceStamps or [] - if sourceStamp: - self.sourceStamps.append(sourceStamp) - if updateSourceStamp is not None: - self.updateSourceStamp = updateSourceStamp - else: - self.updateSourceStamp = not (alwaysUseLatest or self.sourceStamps) - self.alwaysUseLatest = alwaysUseLatest - self.waitForFinish = waitForFinish - properties = {} - properties.update(set_properties) - for i in copy_properties: - properties[i] = Property(i) - self.set_properties = properties - self.running = False - self.ended = False - LoggingBuildStep.__init__(self, **kwargs) - - def interrupt(self, reason): - if self.running and not self.ended: - self.step_status.setText(["interrupted"]) - return self.end(EXCEPTION) - - def end(self, result): - if not self.ended: - self.ended = True - return self.finished(result) - - # Create the properties that are used for the trigger - def createTriggerProperties(self): - # make a new properties object from a dict rendered by the old - # properties object - trigger_properties = Properties() - trigger_properties.update(self.set_properties, "Trigger") - for prop in trigger_properties.asDict(): - if prop not in self.set_properties: - self.set_properties[prop] = Property(prop) - return trigger_properties - - # Get all scheduler instances that were configured - # A tuple of (triggerables, invalidnames) is returned - def getSchedulers(self): - all_schedulers = self.build.builder.botmaster.parent.allSchedulers() - all_schedulers = dict([(sch.name, sch) for sch in all_schedulers]) - invalid_schedulers = [] - triggered_schedulers = [] - # don't fire any schedulers if we discover an unknown one - for scheduler in self.schedulerNames: - scheduler = scheduler - if all_schedulers.has_key(scheduler): - sch = all_schedulers[scheduler] - if ITriggerableScheduler.providedBy(sch): - triggered_schedulers.append(sch) - else: - invalid_schedulers.append(scheduler) - else: - invalid_schedulers.append(scheduler) - - return (triggered_schedulers, invalid_schedulers) - - def prepareSourcestampListForTrigger(self): - if self.sourceStamps: - ss_for_trigger = {} - for ss in self.sourceStamps: - codebase = ss.get('codebase','') - assert codebase not in ss_for_trigger, "codebase specified multiple times" - ss_for_trigger[codebase] = ss - return ss_for_trigger - - if self.alwaysUseLatest: - return {} - - # start with the sourcestamps from current build - ss_for_trigger = {} - objs_from_build = self.build.getAllSourceStamps() - for ss in objs_from_build: - ss_for_trigger[ss.codebase] = ss.asDict() - - # overrule revision in sourcestamps with got revision - if self.updateSourceStamp: - got = self.build.build_status.getAllGotRevisions() - for codebase in ss_for_trigger: - if codebase in got: - ss_for_trigger[codebase]['revision'] = got[codebase] - - return ss_for_trigger - - @defer.inlineCallbacks - def start(self): - # Get all triggerable schedulers and check if there are invalid schedules - (triggered_schedulers, invalid_schedulers) = self.getSchedulers() - if invalid_schedulers: - self.step_status.setText(['not valid scheduler:'] + invalid_schedulers) - self.end(FAILURE) - return - - self.running = True - - props_to_set = self.createTriggerProperties() - - ss_for_trigger = self.prepareSourcestampListForTrigger() - - dl = [] - nowait = [] - triggered_names = [] - for sch in triggered_schedulers: - if sch.name in self.noWait: - import time - time.sleep(5) - nowait.append(sch.trigger(ss_for_trigger, set_props=props_to_set)) - else: - dl.append(sch.trigger(ss_for_trigger, set_props=props_to_set)) - triggered_names.append(sch.name) - self.step_status.setText(['triggered'] + triggered_names) - - for d in nowait: - d.addErrback(log.err, - '(ignored) while invoking Triggerable schedulers:') - - if self.waitForFinish: - rclist = yield defer.DeferredList(dl, consumeErrors=1) - else: - # do something to handle errors - for d in dl: - d.addErrback(log.err, - '(ignored) while invoking Triggerable schedulers:') - rclist = None - self.end(SUCCESS) - return - - was_exception = was_failure = False - brids = {} - for was_cb, results in rclist: - if isinstance(results, tuple): - results, some_brids = results - brids.update(some_brids) - - if not was_cb: - was_exception = True - log.err(results) - continue - - if results==FAILURE: - was_failure = True - - if was_exception: - result = EXCEPTION - elif was_failure: - result = FAILURE - else: - result = SUCCESS - - if brids: - master = self.build.builder.botmaster.parent - def add_links(res): - # reverse the dictionary lookup for brid to builder name - brid_to_bn = dict((_brid,_bn) for _bn,_brid in brids.iteritems()) - - for was_cb, builddicts in res: - if was_cb: - for build in builddicts: - bn = brid_to_bn[build['brid']] - num = build['number'] - - url = master.status.getURLForBuild(bn, num) - self.step_status.addURL("%s #%d" % (bn,num), url) - - return self.end(result) - - builddicts = [master.db.builds.getBuildsForRequest(br) for br in brids.values()] - dl = defer.DeferredList(builddicts, consumeErrors=1) - dl.addCallback(add_links) - - self.end(result) - return |