Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Minor style fixes (PEP 8)

  • Loading branch information...
commit fd1816b2cc5c0391bc1ca0c959b1730c585061a8 1 parent 9b2ab82
Andreas Bolka authored
Showing with 6 additions and 6 deletions.
  1. +6 −6 beanstalkc.py
12 beanstalkc.py
View
@@ -25,7 +25,7 @@
DEFAULT_HOST = 'localhost'
DEFAULT_PORT = 11300
-DEFAULT_PRIORITY = 2**31
+DEFAULT_PRIORITY = 2 ** 31
DEFAULT_TTR = 120
@@ -52,7 +52,7 @@ def __init__(self, host=DEFAULT_HOST, port=DEFAULT_PORT, parse_yaml=True,
except ImportError:
logging.error('Failed to load PyYAML, will not parse YAML')
parse_yaml = False
- self._connect_timeout= connect_timeout
+ self._connect_timeout = connect_timeout
self._parse_yaml = parse_yaml or (lambda x: x)
self.host = host
self.port = port
@@ -93,7 +93,7 @@ def _read_response(self):
def _read_body(self, size):
body = SocketError.wrap(self._socket_file.read, size)
- SocketError.wrap(self._socket_file.read, 2) # trailing crlf
+ SocketError.wrap(self._socket_file.read, 2) # trailing crlf
if size > 0 and not body:
raise SocketError()
return body
@@ -201,12 +201,12 @@ def stats(self):
def stats_tube(self, name):
"""Return a dict of stats about a given tube."""
return self._interact_yaml('stats-tube %s\r\n' % name,
- ['OK'],
- ['NOT_FOUND'])
+ ['OK'],
+ ['NOT_FOUND'])
def pause_tube(self, name, delay):
"""Pause a tube for a given delay time, in seconds."""
- self._interact('pause-tube %s %d\r\n' %(name, delay),
+ self._interact('pause-tube %s %d\r\n' % (name, delay),
['PAUSED'],
['NOT_FOUND'])
Please sign in to comment.
Something went wrong with that request. Please try again.