diff --git a/migrations/versions/0043_view_activity.py b/migrations/versions/0043_view_activity.py
index f589a0938..c69089603 100644
--- a/migrations/versions/0043_view_activity.py
+++ b/migrations/versions/0043_view_activity.py
@@ -20,14 +20,15 @@ def upgrade():
     conn = op.get_bind()
     conn.execute('COMMIT')
     conn.execute("alter type permission_types add value IF NOT EXISTS 'view_activity'")
-    user_services = conn.execute("SELECT * FROM user_to_service").fetchall()
+    user_services = conn.execute("SELECT * FROM user_to_service where user_id "
+                                 "not in (select user_id from permissions "
+                                 "where permission='view_activity')").fetchall()
     for user_service in user_services:
         conn.execute(
             "insert into permissions (id, service_id, user_id, created_at, permission) "
             "values('{0}', '{1}', {2}, now(), 'view_activity')".format(
                 uuid.uuid4(), user_service.service_id, user_service.user_id))
     conn.execute("delete from permissions where permission = 'access_developer_docs'")
-    conn.execute("delete from pg_enum where enumlabel='access_developer_docs'")
     ### end Alembic commands ###
 
 
@@ -35,7 +36,6 @@ def downgrade():
     ### commands auto generated by Alembic - please adjust! ###
     conn = op.get_bind()
     conn.execute("delete from permissions where permission = 'view_activity'")
-    conn.execute("delete from pg_enum where enumlabel = 'view_activity'")
     conn.execute('COMMIT')
     conn.execute("alter type permission_types add value IF NOT EXISTS 'access_developer_docs'")
     manage_api_key_users = conn.execute("SELECT * FROM permissions where permission='manage_api_keys'").fetchall()