"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "buildbot/schedulers/trysched.py" between
buildbot-3.0.2.tar.gz and buildbot-3.1.0.tar.gz

About: Buildbot is a continuous integration testing framework (Python-based). It supports also automation of complex build systems, application deployment, and management of sophisticated software-release processes.

trysched.py  (buildbot-3.0.2):trysched.py  (buildbot-3.1.0)
skipping to change at line 324 skipping to change at line 324
def __init__(self, master, builddict, builderName): def __init__(self, master, builddict, builderName):
self.master = master self.master = master
self.builddict = builddict self.builddict = builddict
self.builderName = builderName self.builderName = builderName
self.consumer = None self.consumer = None
@defer.inlineCallbacks @defer.inlineCallbacks
def remote_subscribe(self, subscriber, interval): def remote_subscribe(self, subscriber, interval):
# subscribe to any new steps.. # subscribe to any new steps..
def stepChanged(key, msg): def stepChanged(key, msg):
log.msg("SC")
if key[-1] == 'started': if key[-1] == 'started':
return subscriber.callRemote('stepStarted', return subscriber.callRemote('stepStarted',
self.builderName, self, msg['name'] , None) self.builderName, self, msg['name'] , None)
elif key[-1] == 'finished': elif key[-1] == 'finished':
return subscriber.callRemote('stepFinished', self.builderName, s elf, msg['name'], return subscriber.callRemote('stepFinished', self.builderName, s elf, msg['name'],
None, msg['results']) None, msg['results'])
return None return None
self.consumer = yield self.master.mq.startConsuming( self.consumer = yield self.master.mq.startConsuming(
stepChanged, stepChanged,
('builds', str(self.builddict['buildid']), 'steps', None, None)) ('builds', str(self.builddict['buildid']), 'steps', None, None))
skipping to change at line 348 skipping to change at line 347
def remote_unsubscribe(self, subscriber): def remote_unsubscribe(self, subscriber):
if self.consumer: if self.consumer:
self.consumer.stopConsuming() self.consumer.stopConsuming()
self.consumer = None self.consumer = None
@defer.inlineCallbacks @defer.inlineCallbacks
def remote_waitUntilFinished(self): def remote_waitUntilFinished(self):
d = defer.Deferred() d = defer.Deferred()
def buildEvent(key, msg): def buildEvent(key, msg):
log.msg("BE")
if key[-1] == 'finished': if key[-1] == 'finished':
d.callback(None) d.callback(None)
consumer = yield self.master.mq.startConsuming( consumer = yield self.master.mq.startConsuming(
buildEvent, buildEvent,
('builds', str(self.builddict['buildid']), None)) ('builds', str(self.builddict['buildid']), None))
yield d # wait for event yield d # wait for event
consumer.stopConsuming() consumer.stopConsuming()
return self # callers expect result=self return self # callers expect result=self
 End of changes. 2 change blocks. 
2 lines changed or deleted 0 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)