You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tooling.apache.org by ar...@apache.org on 2026/04/10 14:36:34 UTC
(tooling-trusted-releases) branch arm updated: #983 - record distribution actions in storage audit log
This is an automated email from the ASF dual-hosted git repository.
arm pushed a commit to branch arm
in repository https://gitbox.apache.org/repos/asf/tooling-trusted-releases.git
The following commit(s) were added to refs/heads/arm by this push:
new adb9c267 #983 - record distribution actions in storage audit log
adb9c267 is described below
commit adb9c267267949bccdf59561fd5ff36763db93c8
Author: Alastair McFarlane <ar...@apache.org>
AuthorDate: Fri Apr 10 15:36:21 2026 +0100
#983 - record distribution actions in storage audit log
---
atr/storage/writers/distributions.py | 24 ++++++++++++++++++++++++
1 file changed, 24 insertions(+)
diff --git a/atr/storage/writers/distributions.py b/atr/storage/writers/distributions.py
index c586a499..a7eef55c 100644
--- a/atr/storage/writers/distributions.py
+++ b/atr/storage/writers/distributions.py
@@ -132,6 +132,12 @@ class CommitteeMember(CommitteeParticipant):
self.__data.add(dist_task)
await self.__data.commit()
await self.__data.refresh(dist_task)
+ self.__write_as.append_to_audit_log(
+ asf_uid=self.__asf_uid,
+ operation="distribution_automate",
+ release_key=str(release_key),
+ platform=platform.name,
+ )
return dist_task
async def record(
@@ -168,6 +174,12 @@ class CommitteeMember(CommitteeParticipant):
if existing is None:
self.__data.add(dist)
await self.__data.commit()
+ self.__write_as.append_to_audit_log(
+ asf_uid=self.__asf_uid,
+ operation="distribution_record",
+ release_key=str(release_key),
+ platform=platform.name,
+ )
return dist, True
# If we're doing production and existing was for staging, upgrade it
if (not staging) and existing.staging:
@@ -183,6 +195,12 @@ class CommitteeMember(CommitteeParticipant):
web_url,
)
if upgraded is not None:
+ self.__write_as.append_to_audit_log(
+ asf_uid=self.__asf_uid,
+ operation="distribution_upgrade",
+ release_key=str(release_key),
+ platform=platform.name,
+ )
return upgraded, False
if existing.pending:
if pending:
@@ -299,3 +317,9 @@ class CommitteeMember(CommitteeParticipant):
).demand(RuntimeError(f"Distribution {release_key} {platform} {owner_namespace} {package} {version} not found"))
await self.__data.delete(distribution)
await self.__data.commit()
+ self.__write_as.append_to_audit_log(
+ asf_uid=self.__asf_uid,
+ operation="distribution_delete",
+ release_key=str(release_key),
+ platform=platform.name,
+ )
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@tooling.apache.org
For additional commands, e-mail: commits-help@tooling.apache.org