[PATCH 3 of 7 evolve-ext] check-code: make pushexperiment.py comply with check-code
Laurent Charignon
lcharignon at fb.com
Fri Dec 4 17:37:13 CST 2015
# HG changeset patch
# User Laurent Charignon <lcharignon at fb.com>
# Date 1449271276 28800
# Fri Dec 04 15:21:16 2015 -0800
# Node ID 291304758df3f7c9757094319b2cec892fa5ba48
# Parent 156d875e81626f3e713f5357e9d728af2b24283a
check-code: make pushexperiment.py comply with check-code
diff --git a/hgext/pushexperiment.py b/hgext/pushexperiment.py
--- a/hgext/pushexperiment.py
+++ b/hgext/pushexperiment.py
@@ -3,7 +3,8 @@
- Add a new wire protocol command to exchange obsolescence markers. Sending the
raw file as a binary instead of using pushkey hack.
- Add a "push done" notification
-- Push obsolescence marker before anything else (This works around the lack of global transaction)
+- Push obsolescence marker before anything else (This works around the lack
+of global transaction)
"""
@@ -61,7 +62,8 @@
def client_notifypushend(self):
"""wire peer command to notify a push is done"""
- self.requirecap('_push_experiment_notifypushend_0', _('hook once push is all done'))
+ self.requirecap('_push_experiment_notifypushend_0',
+ _('hook once push is all done'))
return self._call('push_experiment_notifypushend_0')
@@ -75,7 +77,7 @@
def augmented_push(orig, repo, remote, *args, **kwargs):
"""push wrapped that call the wire protocol command"""
if not remote.canpush():
- raise util.Abort(_("destination does not support push"))
+ raise error.Abort(_("destination does not support push"))
if (obsolete.isenabled(repo, obsolete.exchangeopt) and repo.obsstore
and remote.capable('_push_experiment_pushobsmarkers_0')):
# push marker early to limit damage of pushing too early.
@@ -104,8 +106,10 @@
def extsetup(ui):
wireproto.wirepeer.push_experiment_pushobsmarkers_0 = client_pushobsmarkers
wireproto.wirepeer.push_experiment_notifypushend_0 = client_notifypushend
- wireproto.commands['push_experiment_pushobsmarkers_0'] = (srv_pushobsmarkers, '')
- wireproto.commands['push_experiment_notifypushend_0'] = (srv_notifypushend, '')
+ wireproto.commands['push_experiment_pushobsmarkers_0'] = \
+ (srv_pushobsmarkers, '')
+ wireproto.commands['push_experiment_notifypushend_0'] = \
+ (srv_notifypushend, '')
extensions.wrapfunction(wireproto, 'capabilities', capabilities)
extensions.wrapfunction(obsolete, 'syncpush', syncpush)
extensions.wrapfunction(localrepo.localrepository, 'push', augmented_push)
More information about the Mercurial-devel
mailing list