fixup! fixup! fixup! fixup! fixup! clean up orphaned blobs

migrations/02_add_archive_count.py

@@ -93,13 +93,17 @@
         )
     ).returning(Archive.c.uri)
     with connection.begin() as transaction:
+        for row in transaction.execute(statement).fetchall():
+            key = get_key_for_url(bucket, row["uri"])
+            print(f"delete {key}")
+            # bucket.Object(key).delete()
         transaction.rollback()
     # print(
     #     statement.compile(
     #         dialect=engine.dialect, compile_kwargs={"literal_binds": True}
     #     )
     # )
-    # sys.exit(0)
+    sys.exit(0)
 
     in_bucket = {summary.key: summary.size for summary in bucket.objects.all()}
     print(