Applied autopep8

autopep8 -v -j 8 --max-line-length 120 --in-place --recursive

Author: Byron

doc/source/conf.py

@@ -11,7 +11,8 @@
 # All configuration values have a default; values that are commented out
 # serve to show the default.
 
-import sys, os
+import sys
+import os
 
 # If extensions (or modules to document with autodoc) are in another directory,
 # add these directories to sys.path here. If the directory is relative to the
@@ -171,8 +172,8 @@
 # Grouping the document tree into LaTeX files. List of tuples
 # (source start file, target name, title, author, documentclass [howto/manual]).
 latex_documents = [
-  ('index', 'GitDB.tex', u'GitDB Documentation',
-   u'Sebastian Thiel', 'manual'),
+    ('index', 'GitDB.tex', u'GitDB Documentation',
+     u'Sebastian Thiel', 'manual'),
 ]
 
 # The name of an image file (relative to this directory) to place at the top of

gitdb/__init__.py

@@ -8,6 +8,8 @@
 import os
 
 #{ Initialization
+
+
 def _init_externals():
     """Initialize external projects by putting them into the path"""
     for module in ('smmap',):
@@ -17,8 +19,8 @@ def _init_externals():
             __import__(module)
         except ImportError:
             raise ImportError("'%s' could not be imported, assure it is located in your PYTHONPATH" % module)
-        #END verify import
-    #END handel imports
+        # END verify import
+    # END handel imports
 
 #} END initialization
 

gitdb/base.py

@@ -11,12 +11,14 @@
 )
 
 __all__ = ('OInfo', 'OPackInfo', 'ODeltaPackInfo',
-            'OStream', 'OPackStream', 'ODeltaPackStream',
-            'IStream', 'InvalidOInfo', 'InvalidOStream' )
+           'OStream', 'OPackStream', 'ODeltaPackStream',
+           'IStream', 'InvalidOInfo', 'InvalidOStream')
 
 #{ ODB Bases
 
+
 class OInfo(tuple):
+
     """Carries information about an object in an ODB, provding information
     about the binary sha of the object, the type_string as well as the uncompressed size
     in bytes.
@@ -62,6 +64,7 @@ def size(self):
 
 
 class OPackInfo(tuple):
+
     """As OInfo, but provides a type_id property to retrieve the numerical type id, and
     does not include a sha.
 
@@ -71,7 +74,7 @@ class OPackInfo(tuple):
     __slots__ = tuple()
 
     def __new__(cls, packoffset, type, size):
-        return tuple.__new__(cls, (packoffset,type, size))
+        return tuple.__new__(cls, (packoffset, type, size))
 
     def __init__(self, *args):
         tuple.__init__(self)
@@ -98,6 +101,7 @@ def size(self):
 
 
 class ODeltaPackInfo(OPackInfo):
+
     """Adds delta specific information,
     Either the 20 byte sha which points to some object in the database,
     or the negative offset from the pack_offset, so that pack_offset - delta_info yields
@@ -115,6 +119,7 @@ def delta_info(self):
 
 
 class OStream(OInfo):
+
     """Base for object streams retrieved from the database, providing additional
     information about the stream.
     Generally, ODB streams are read-only as objects are immutable"""
@@ -124,7 +129,6 @@ def __new__(cls, sha, type, size, stream, *args, **kwargs):
         """Helps with the initialization of subclasses"""
         return tuple.__new__(cls, (sha, type, size, stream))
 
-
     def __init__(self, *args, **kwargs):
         tuple.__init__(self)
 
@@ -141,6 +145,7 @@ def stream(self):
 
 
 class ODeltaStream(OStream):
+
     """Uses size info of its stream, delaying reads"""
 
     def __new__(cls, sha, type, size, stream, *args, **kwargs):
@@ -157,6 +162,7 @@ def size(self):
 
 
 class OPackStream(OPackInfo):
+
     """Next to pack object information, a stream outputting an undeltified base object
     is provided"""
     __slots__ = tuple()
@@ -176,13 +182,13 @@ def stream(self):
 
 
 class ODeltaPackStream(ODeltaPackInfo):
+
     """Provides a stream outputting the uncompressed offset delta information"""
     __slots__ = tuple()
 
     def __new__(cls, packoffset, type, size, delta_info, stream):
         return tuple.__new__(cls, (packoffset, type, size, delta_info, stream))
 
-
     #{ Stream Reader Interface
     def read(self, size=-1):
         return self[4].read(size)
@@ -194,6 +200,7 @@ def stream(self):
 
 
 class IStream(list):
+
     """Represents an input content stream to be fed into the ODB. It is mutable to allow
     the ODB to record information about the operations outcome right in this instance.
 
@@ -246,7 +253,6 @@ def _binsha(self):
 
     binsha = property(_binsha, _set_binsha)
 
-
     def _type(self):
         return self[1]
 
@@ -275,6 +281,7 @@ def _set_stream(self, stream):
 
 
 class InvalidOInfo(tuple):
+
     """Carries information about a sha identifying an object which is invalid in
     the queried database. The exception attribute provides more information about
     the cause of the issue"""
@@ -301,6 +308,7 @@ def error(self):
 
 
 class InvalidOStream(InvalidOInfo):
+
     """Carries information about an invalid ODB stream"""
     __slots__ = tuple()
 

gitdb/db/base.py

@@ -19,11 +19,11 @@
 from functools import reduce
 
 
-
 __all__ = ('ObjectDBR', 'ObjectDBW', 'FileDBBase', 'CompoundDB', 'CachingDB')
 
 
 class ObjectDBR(object):
+
     """Defines an interface for object database lookup.
     Objects are identified either by their 20 byte bin sha"""
 
@@ -61,6 +61,7 @@ def sha_iter(self):
 
 
 class ObjectDBW(object):
+
     """Defines an interface to create objects in the database"""
 
     def __init__(self, *args, **kwargs):
@@ -100,6 +101,7 @@ def store(self, istream):
 
 
 class FileDBBase(object):
+
     """Provides basic facilities to retrieve files of interest, including
     caching facilities to help mapping hexsha's to objects"""
 
@@ -113,7 +115,6 @@ def __init__(self, root_path):
         super(FileDBBase, self).__init__()
         self._root_path = root_path
 
-
     #{ Interface
     def root_path(self):
         """:return: path at which this db operates"""
@@ -128,6 +129,7 @@ def db_path(self, rela_path):
 
 
 class CachingDB(object):
+
     """A database which uses caches to speed-up access"""
 
     #{ Interface
@@ -143,8 +145,6 @@ def update_cache(self, force=False):
     # END interface
 
 
-
-
 def _databases_recursive(database, output):
     """Fill output list with database from db, in order. Deals with Loose, Packed
     and compound databases."""
@@ -159,10 +159,12 @@ def _databases_recursive(database, output):
 
 
 class CompoundDB(ObjectDBR, LazyMixin, CachingDB):
+
     """A database which delegates calls to sub-databases.
 
     Databases are stored in the lazy-loaded _dbs attribute.
     Define _set_cache_ to update it with your databases"""
+
     def _set_cache_(self, attr):
         if attr == '_dbs':
             self._dbs = list()
@@ -207,7 +209,7 @@ def stream(self, sha):
 
     def size(self):
         """:return: total size of all contained databases"""
-        return reduce(lambda x,y: x+y, (db.size() for db in self._dbs), 0)
+        return reduce(lambda x, y: x + y, (db.size() for db in self._dbs), 0)
 
     def sha_iter(self):
         return chain(*(db.sha_iter() for db in self._dbs))

gitdb/db/git.py

@@ -20,6 +20,7 @@
 
 
 class GitDB(FileDBBase, ObjectDBW, CompoundDB):
+
     """A git-style object database, which contains all objects in the 'objects'
     subdirectory"""
     # Configuration
@@ -41,8 +42,8 @@ def _set_cache_(self, attr):
             self._dbs = list()
             loose_db = None
             for subpath, dbcls in ((self.packs_dir, self.PackDBCls),
-                                    (self.loose_dir, self.LooseDBCls),
-                                    (self.alternates_dir, self.ReferenceDBCls)):
+                                   (self.loose_dir, self.LooseDBCls),
+                                   (self.alternates_dir, self.ReferenceDBCls)):
                 path = self.db_path(subpath)
                 if os.path.exists(path):
                     self._dbs.append(dbcls(path))

gitdb/db/loose.py

@@ -57,10 +57,11 @@
 import os
 
 
-__all__ = ( 'LooseObjectDB', )
+__all__ = ('LooseObjectDB', )
 
 
 class LooseObjectDB(FileDBBase, ObjectDBR, ObjectDBW):
+
     """A database which operates on loose object files"""
 
     # CONFIGURATION
@@ -73,7 +74,6 @@ class LooseObjectDB(FileDBBase, ObjectDBR, ObjectDBW):
     if os.name == 'nt':
         new_objects_mode = int("644", 8)
 
-
     def __init__(self, root_path):
         super(LooseObjectDB, self).__init__(root_path)
         self._hexsha_to_file = dict()
@@ -164,7 +164,7 @@ def info(self, sha):
 
     def stream(self, sha):
         m = self._map_loose_object(sha)
-        type, size, stream = DecompressMemMapReader.new(m, close_on_deletion = True)
+        type, size, stream = DecompressMemMapReader.new(m, close_on_deletion=True)
         return OStream(sha, type, size, stream)
 
     def has_object(self, sha):
@@ -199,7 +199,7 @@ def store(self, istream):
                 else:
                     # write object with header, we have to make a new one
                     write_object(istream.type, istream.size, istream.read, writer.write,
-                                    chunk_size=self.stream_chunk_size)
+                                 chunk_size=self.stream_chunk_size)
                 # END handle direct stream copies
             finally:
                 if tmp_path:

gitdb/db/mem.py

@@ -28,7 +28,9 @@
 
 __all__ = ("MemoryDB", )
 
+
 class MemoryDB(ObjectDBR, ObjectDBW):
+
     """A memory database stores everything to memory, providing fast IO and object
     retrieval. It should be used to buffer results and obtain SHAs before writing
     it to the actual physical storage, as it allows to query whether object already
@@ -85,7 +87,6 @@ def sha_iter(self):
         except AttributeError:
             return self._cache.keys()
 
-
     #{ Interface
     def stream_copy(self, sha_iter, odb):
         """Copy the streams as identified by sha's yielded by sha_iter into the given odb

gitdb/db/pack.py

@@ -31,6 +31,7 @@
 
 
 class PackedDB(FileDBBase, ObjectDBR, CachingDB, LazyMixin):
+
     """A database operating on a set of object packs"""
 
     # sort the priority list every N queries
@@ -113,7 +114,7 @@ def sha_iter(self):
 
     def size(self):
         sizes = [item[1].index().size() for item in self._entities]
-        return reduce(lambda x,y: x+y, sizes, 0)
+        return reduce(lambda x, y: x + y, sizes, 0)
 
     #} END object db read
 
@@ -127,7 +128,6 @@ def store(self, istream):
 
     #} END object db write
 
-
     #{ Interface
 
     def update_cache(self, force=False):
@@ -177,7 +177,7 @@ def update_cache(self, force=False):
 
     def entities(self):
         """:return: list of pack entities operated upon by this database"""
-        return [ item[1] for item in self._entities ]
+        return [item[1] for item in self._entities]
 
     def partial_to_complete_sha(self, partial_binsha, canonical_length):
         """:return: 20 byte sha as inferred by the given partial binary sha

gitdb/db/ref.py

@@ -8,7 +8,9 @@
 
 __all__ = ('ReferenceDB', )
 
+
 class ReferenceDB(CompoundDB):
+
     """A database consisting of database referred to in a file"""
 
     # Configuration