cont

Author: chaen

diracx-db/src/diracx/db/sql/auth/db.py

@@ -72,7 +72,18 @@ async def post_create(cls, conn: AsyncConnection) -> None:
                 print("CHRIS BOOM")
                 print(query)
 
-                partition_names = (await conn.execute(query)).all()
+                await conn.execute(query)
+
+                print("CHIS HOW DOES IT LOOK NOW?")
+                query = text(
+                    "SELECT PARTITION_NAME FROM information_schema.partitions "
+                    "WHERE TABLE_NAME = :table_name AND PARTITION_NAME is not NULL"
+                )
+                partition_names = (
+                    await conn.execute(query, {"table_name": "RefreshTokens"})
+                ).all()
+                print(partition_names)
+                print("CHRIS GOOD JOB")
 
     async def device_flow_validate_user_code(
         self, user_code: str, max_validity: int