diff --git a/zuul/merger/client.py b/zuul/merger/client.py index 069cbf5a74..e16419541d 100644 --- a/zuul/merger/client.py +++ b/zuul/merger/client.py @@ -113,12 +113,6 @@ class MergeClient(object): files=files) self.submitJob('merger:merge', data, build_set, precedence) - def updateRepo(self, connection_name, project_name, build_set, - precedence=zuul.model.PRECEDENCE_NORMAL): - data = dict(connection=connection_name, - project=project_name) - self.submitJob('merger:update', data, build_set, precedence) - def getFiles(self, connection_name, project_name, branch, files, precedence=zuul.model.PRECEDENCE_HIGH): data = dict(connection=connection_name, diff --git a/zuul/merger/server.py b/zuul/merger/server.py index 04fd03b17e..c09d7ba5e7 100644 --- a/zuul/merger/server.py +++ b/zuul/merger/server.py @@ -67,7 +67,6 @@ class MergeServer(object): def register(self): self.worker.registerFunction("merger:merge") - self.worker.registerFunction("merger:update") self.worker.registerFunction("merger:cat") def stop(self): @@ -88,9 +87,6 @@ class MergeServer(object): if job.name == 'merger:merge': self.log.debug("Got merge job: %s" % job.unique) self.merge(job) - elif job.name == 'merger:update': - self.log.debug("Got update job: %s" % job.unique) - self.update(job) elif job.name == 'merger:cat': self.log.debug("Got cat job: %s" % job.unique) self.cat(job) @@ -119,13 +115,6 @@ class MergeServer(object): result['commit'] = ret job.sendWorkComplete(json.dumps(result)) - def update(self, job): - args = json.loads(job.arguments) - self.merger.updateRepo(args['connection'], args['project']) - result = dict(updated=True, - zuul_url=self.zuul_url) - job.sendWorkComplete(json.dumps(result)) - def cat(self, job): args = json.loads(job.arguments) self.merger.updateRepo(args['connection'], args['project'])