ruff: 2025 format

ampel/ztf/archive/server/app.py

@@ -159,7 +159,7 @@ def post_alert_chunk(
     alerts, schema = content_and_schema
 
     blob, ranges = pack_records(alerts, schema)
-    key = f'{hashlib.sha256(json.dumps(sorted(alert["candid"] for alert in alerts)).encode("utf-8")).hexdigest()}.avro'
+    key = f"{hashlib.sha256(json.dumps(sorted(alert['candid'] for alert in alerts)).encode('utf-8')).hexdigest()}.avro"
     md5 = base64.b64encode(hashlib.md5(blob).digest()).decode("utf-8")
 
     obj = bucket.Object(key)
@@ -766,7 +766,9 @@ def create_stream_from_query(
         ) from None
 
     conn.execute(
-        sqlalchemy.text(f"set statement_timeout={settings.stream_query_timeout*1000};")
+        sqlalchemy.text(
+            f"set statement_timeout={settings.stream_query_timeout * 1000};"
+        )
     )
     group_id = archive._create_read_queue(conn, name, query.chunk_size)  # noqa: SLF001
     conn.commit()

migrations/01_update_hpx.py

@@ -79,4 +79,4 @@
             ],
         )
         dt = time.time() - t0
-        log.info(f"updated {len(rows)/dt:.1f} rows/s")
+        log.info(f"updated {len(rows) / dt:.1f} rows/s")

tests/fixtures.py

@@ -60,7 +60,7 @@ def archive(integration):
                     "ARCHIVE_WRITE_USER=ampel-client",
                     "-P",
                     "-v",
-                    f"{Path(__file__).parent/'test-data'/'initdb'/'archive'}:/docker-entrypoint-initdb.d",
+                    f"{Path(__file__).parent / 'test-data' / 'initdb' / 'archive'}:/docker-entrypoint-initdb.d",
                     POSTGRES_IMAGE,
                 ],
             )

tests/test_archivedb.py

@@ -665,4 +665,4 @@ def test_seekable_avro(alert_generator, cutouts: bool):
                 assert reco == alert
                 break
         else:
-            raise ValueError(f'{alert["candid"]} not found')
+            raise ValueError(f"{alert['candid']} not found")

tests/test_server.py

@@ -260,15 +260,15 @@ async def test_programid_auth(
         assert response.status_code == status.HTTP_200_OK
         assert mock_db.get_alerts_for_object.call_args.kwargs[
             "programid"
-        ] == params.get(
-            "programid"
-        ), "programid is passed through for partnership token"
+        ] == params.get("programid"), (
+            "programid is passed through for partnership token"
+        )
     else:
         assert response.status_code == status_code
         if response.status_code == status.HTTP_200_OK:
-            assert (
-                mock_db.get_alerts_for_object.call_args.kwargs["programid"] == 1
-            ), "non-partnership tokens always query programid 1"
+            assert mock_db.get_alerts_for_object.call_args.kwargs["programid"] == 1, (
+                "non-partnership tokens always query programid 1"
+            )
 
 
 @pytest.mark.asyncio