Run format-webkit on webkitpy code (without string conversion).

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 165 matching lines @@
                     self._caller.handle(message.name, message.src, *message.args)
                     continue
                 method = getattr(self, '_handle_' + message.name)
                 assert method, 'bad message %s' % repr(message)
                 method(message.src, *message.args)
         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)
+        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):
+    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 40 matching lines @@
                 if message.from_user:
                     worker.handle(message.name, message.src, *message.args)
                     self._yield_to_manager()
                 else:
                     assert message.name == 'stop', 'bad message %s' % repr(message)
                     break
 
             _log.debug("%s exiting" % self.name)
         except Queue.Empty:
             assert False, '%s: ran out of messages in worker queue.' % self.name
-        except KeyboardInterrupt, e:
+        except KeyboardInterrupt as e:
             self._raise(sys.exc_info())
-        except Exception, e:
+        except Exception as e:
             self._raise(sys.exc_info())
         finally:
             try:
                 if hasattr(worker, 'stop'):
                     worker.stop()
             finally:
                 self._post(name='done', args=(), from_user=False)
             self._close()
 
     def stop_running(self):
@@ skipping 42 matching lines @@
 
 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)