Run auto-formatter (autopep8) on webkitpy.

third_party/WebKit/Tools/Scripts/webkitpy/common/message_pool.py

 # Copyright (C) 2011 Google Inc. All rights reserved.
 #
 # Redistribution and use in source and binary forms, with or without
 # modification, are permitted provided that the following conditions are
 # met:
 #
 #     * Redistributions of source code must retain the above copyright
 # notice, this list of conditions and the following disclaimer.
 #     * Redistributions in binary form must reproduce the above
 # copyright notice, this list of conditions and the following disclaimer
@@ skipping 44 matching lines @@
 
 _log = logging.getLogger(__name__)
 
 
 def get(caller, worker_factory, num_workers, host=None):
     """Returns an object that exposes a run() method that takes a list of test shards and runs them in parallel."""
     return _MessagePool(caller, worker_factory, num_workers, host)
 
 
 class _MessagePool(object):
+
     def __init__(self, caller, worker_factory, num_workers, host=None):
         self._caller = caller
         self._worker_factory = worker_factory
         self._num_workers = num_workers
         self._workers = []
         self._workers_stopped = set()
         self._host = host
         self._name = 'manager'
         self._running_inline = (self._num_workers == 1)
         if self._running_inline:
@@ skipping 21 matching lines @@
         self.wait()
 
     def _start_workers(self):
         assert not self._workers
         self._workers_stopped = set()
         host = None
         if self._running_inline or self._can_pickle(self._host):
             host = self._host
 
         for worker_number in xrange(self._num_workers):
-            worker = _Worker(host, self._messages_to_manager, self._messages_to_worker, self._worker_factory, worker_number, self._running_inline, self if self._running_inline else None, self._worker_log_level())
+            worker = _Worker(host, self._messages_to_manager, self._messages_to_worker, self._worker_factory,
+                             worker_number, self._running_inline, self if self._running_inline else None, self._worker_log_level())
             self._workers.append(worker)
             worker.start()
 
     def _worker_log_level(self):
         log_level = logging.NOTSET
         for handler in logging.root.handlers:
             if handler.level != logging.NOTSET:
                 if log_level == logging.NOTSET:
                     log_level = handler.level
                 else:
@@ skipping 63 matching lines @@
         except Queue.Empty:
             pass
 
 
 class WorkerException(BaseException):
     """Raised when we receive an unexpected/unknown exception from a worker."""
     pass
 
 
 class _Message(object):
+
     def __init__(self, src, message_name, message_args, from_user, logs):
         self.src = src
         self.name = message_name
         self.args = message_args
         self.from_user = from_user
         self.logs = logs
 
     def __repr__(self):
         return '_Message(src=%s, name=%s, args=%s, from_user=%s, logs=%s)' % (self.src, self.name, self.args, self.from_user, self.logs)
 
 
 class _Worker(multiprocessing.Process):
+
     def __init__(self, host, messages_to_manager, messages_to_worker, worker_factory, worker_number, running_inline, manager, log_level):
         super(_Worker, self).__init__()
         self.host = host
         self.worker_number = worker_number
         self.name = 'worker/%d' % worker_number
         self.log_messages = []
         self.log_level = log_level
         self._running = False
         self._running_inline = running_inline
         self._manager = manager
@@ skipping 98 matching lines @@
         # so we remove them to avoid duplicate logging.
         for h in self._logger.handlers:
             self._logger.removeHandler(h)
 
         self._log_handler = _WorkerLogHandler(self)
         self._logger.addHandler(self._log_handler)
         self._logger.setLevel(self.log_level)
 
 
 class _WorkerLogHandler(logging.Handler):
+
     def __init__(self, worker):
         logging.Handler.__init__(self)
         self._worker = worker
         self.setLevel(worker.log_level)
 
     def emit(self, record):
         self._worker.log_messages.append(record)