This is an automated email from the ASF dual-hosted git repository.
sbp pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/tooling-trusted-releases.git
The following commit(s) were added to refs/heads/main by this push:
new 2a7d4ea7 Remove unnecessary test endpoint
2a7d4ea7 is described below
commit 2a7d4ea7e622caa145980046d627044e72d5908f
Author: Dave Fisher <[email protected]>
AuthorDate: Fri Feb 27 14:51:44 2026 -0800
Remove unnecessary test endpoint
---
atr/admin/__init__.py | 34 ----------------------------------
1 file changed, 34 deletions(-)
diff --git a/atr/admin/__init__.py b/atr/admin/__init__.py
index 0a97d2f8..8fa120fd 100644
--- a/atr/admin/__init__.py
+++ b/atr/admin/__init__.py
@@ -53,7 +53,6 @@ import atr.paths as paths
import atr.principal as principal
import atr.storage as storage
import atr.storage.outcome as outcome
-import atr.storage.types as types
import atr.tasks as tasks
import atr.template as template
import atr.util as util
@@ -885,39 +884,6 @@ async def tasks_recent(session: web.Committer, minutes:
int) -> str:
return await template.blank(f"Recent Tasks ({minutes}m)",
content=page.collect())
[email protected]("/test")
-async def test(session: web.Committer) -> web.QuartResponse:
- """Test the storage layer."""
- import atr.storage as storage
-
- async with util.create_secure_session() as aiohttp_client_session:
- url = "https://downloads.apache.org/zeppelin/KEYS";
- async with aiohttp_client_session.get(url) as response:
- keys_file_text = await response.text()
-
- async with storage.write(session) as write:
- wacm = write.as_committee_member("tooling")
- start = time.perf_counter_ns()
- outcomes: outcome.List[types.Key] = await
wacm.keys.ensure_stored(keys_file_text)
- end = time.perf_counter_ns()
- log.info(f"Upload of {util.plural(outcomes.result_count, 'key')} took
{end - start} ns")
- for ocr in outcomes.results():
- log.info(f"Uploaded key: {type(ocr)} {ocr.key_model.fingerprint}")
- for oce in outcomes.errors():
- log.error(f"Error uploading key: {type(oce)} {oce}")
- parsed_count = outcomes.result_predicate_count(lambda k: k.status ==
types.KeyStatus.PARSED)
- inserted_count = outcomes.result_predicate_count(lambda k: k.status ==
types.KeyStatus.INSERTED)
- linked_count = outcomes.result_predicate_count(lambda k: k.status ==
types.KeyStatus.LINKED)
- inserted_and_linked_count = outcomes.result_predicate_count(
- lambda k: k.status == types.KeyStatus.INSERTED_AND_LINKED
- )
- log.info(f"Parsed: {parsed_count}")
- log.info(f"Inserted: {inserted_count}")
- log.info(f"Linked: {linked_count}")
- log.info(f"InsertedAndLinked: {inserted_and_linked_count}")
- return web.TextResponse(str(wacm))
-
-
@admin.get("/toggle-view")
async def toggle_view_get(session: web.Committer) -> str:
"""Display the page with a button to toggle between admin and user
views."""
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
