diff --git a/muranoapi/db/migrate_repo/versions/007_instance_table_extended.py b/muranoapi/db/migrate_repo/versions/007_instance_table_extended.py
index 01486014..d80cd16d 100644
--- a/muranoapi/db/migrate_repo/versions/007_instance_table_extended.py
+++ b/muranoapi/db/migrate_repo/versions/007_instance_table_extended.py
@@ -21,16 +21,20 @@ meta = schema.MetaData()
 def upgrade(migrate_engine):
     meta.bind = migrate_engine
     table = schema.Table('instance', meta, autoload=True)
-    table.rename('instance_stats')
-    table.delete()
-    type_name = schema.Column('type_name', types.String(512), nullable=False)
-    type_name.create(table)
-    type_title = schema.Column('type_title', types.String(512))
-    type_title.create(table)
-    unit_count = schema.Column('unit_count', types.Integer())
-    unit_count.create(table)
-    tenant_id = schema.Column('tenant_id', types.String(32), nullable=False)
-    tenant_id.create(table)
+    table.drop()
+    table = schema.Table(
+        'instance_stats',
+        meta,
+        schema.Column('environment_id', types.String(100), primary_key=True),
+        schema.Column('instance_id', types.String(100), primary_key=True),
+        schema.Column('instance_type', types.Integer, nullable=False),
+        schema.Column('created', types.Integer, nullable=False),
+        schema.Column('destroyed', types.Integer, nullable=True),
+        schema.Column('type_name', types.String(512), nullable=False),
+        schema.Column('type_title', types.String(512)),
+        schema.Column('unit_count', types.Integer()),
+        schema.Column('tenant_id', types.String(32), nullable=False))
+    table.create()
 
 
 def downgrade(migrate_engine):