This is an automated email from the ASF dual-hosted git repository. wave pushed a commit to branch remove-unnecessary-test-endpoint in repository https://gitbox.apache.org/repos/asf/tooling-trusted-releases.git
commit 737c887c54b09af66fa1aa8dfc791fd5defc09d1 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]
