fix backend variable name
[pithos] / other / migrate.py
index de2146d..ded082c 100644 (file)
@@ -1,20 +1,20 @@
 #!/usr/bin/env python
 
-# Copyright 2011 GRNET S.A. All rights reserved.
-# 
+# Copyright 2011-2012 GRNET S.A. All rights reserved.
+#
 # Redistribution and use in source and binary forms, with or
 # without modification, are permitted provided that the following
 # conditions are met:
-# 
+#
 #   1. Redistributions of source code must retain the above
 #      copyright notice, this list of conditions and the following
 #      disclaimer.
-# 
+#
 #   2. Redistributions in binary form must reproduce the above
 #      copyright notice, this list of conditions and the following
 #      disclaimer in the documentation and/or other materials
 #      provided with the distribution.
-# 
+#
 # THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
 # OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
 # WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
@@ -27,7 +27,7 @@
 # LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
 # ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
 # POSSIBILITY OF SUCH DAMAGE.
-# 
+#
 # The views and conclusions contained in the software and
 # documentation are those of the authors and should not be
 # interpreted as representing official policies, either expressed
@@ -41,41 +41,43 @@ from django.conf import settings
 
 from pithos.backends.modular import ModularBackend
 
+
 class Migration(object):
     def __init__(self, db):
         self.engine = create_engine(db)
         self.metadata = MetaData(self.engine)
         #self.engine.echo = True
         self.conn = self.engine.connect()
-        
+
         options = getattr(settings, 'BACKEND', None)[1]
         self.backend = ModularBackend(*options)
-    
+
     def execute(self):
         pass
 
+
 class Cache():
     def __init__(self, db):
         self.engine = create_engine(db)
         metadata = MetaData(self.engine)
-        
-        columns=[]
+
+        columns = []
         columns.append(Column('path', String(2048), primary_key=True))
         columns.append(Column('hash', String(255)))
         self.files = Table('files', metadata, *columns)
         self.conn = self.engine.connect()
         self.engine.echo = True
         metadata.create_all(self.engine)
-    
+
     def put(self, path, hash):
         # Insert or replace.
-        s = self.files.delete().where(self.files.c.path==path)
+        s = self.files.delete().where(self.files.c.path == path)
         r = self.conn.execute(s)
         r.close()
         s = self.files.insert()
         r = self.conn.execute(s, {'path': path, 'hash': hash})
         r.close()
-    
+
     def get(self, path):
         s = select([self.files.c.hash], self.files.c.path == path)
         r = self.conn.execute(s)
@@ -83,4 +85,4 @@ class Cache():
         r.close()
         if not l:
             return l
-        return l[0]
\ No newline at end of file
+        return l[0]