This is an automated email from the ASF dual-hosted git repository.
arm 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 64c6eb2 #216 - Handle correct exceptions now distributions is
rewired. Don't allow retries of manual record.
64c6eb2 is described below
commit 64c6eb251961d90a0c83f95dbe7c09c900d187a8
Author: Alastair McFarlane <[email protected]>
AuthorDate: Fri Jan 30 16:43:24 2026 +0000
#216 - Handle correct exceptions now distributions is rewired. Don't allow
retries of manual record.
---
atr/post/distribution.py | 2 +-
atr/tasks/distribution.py | 8 ++++----
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/atr/post/distribution.py b/atr/post/distribution.py
index 438a16a..e393682 100644
--- a/atr/post/distribution.py
+++ b/atr/post/distribution.py
@@ -176,7 +176,7 @@ async def record_form_process_page(
release_name=release.name,
staging=staging,
dd=dd,
- allow_retries=True,
+ allow_retries=False,
)
except storage.AccessError as e:
# Instead of calling record_form_page_new, redirect with error
message
diff --git a/atr/tasks/distribution.py b/atr/tasks/distribution.py
index 36caabf..2ca45f6 100644
--- a/atr/tasks/distribution.py
+++ b/atr/tasks/distribution.py
@@ -20,9 +20,10 @@ import pydantic
import atr.db as db
import atr.log as log
-import atr.models.distribution as distribution
+import atr.models as models
import atr.models.results as results
import atr.models.schema as schema
+import atr.shared.distribution as distribution
import atr.storage as storage
import atr.tasks as tasks
import atr.tasks.checks as checks
@@ -45,7 +46,7 @@ async def status_check(args: DistributionStatusCheckArgs, *,
task_id: int | None
dists = await data.distribution(pending=True, _with_release=True,
_with_release_project=True).all()
for dist in dists:
name = f"{dist.platform} {dist.owner_namespace} {dist.package}
{dist.version}"
- dd = distribution.Data(
+ dd = models.distribution.Data(
platform=dist.platform,
owner_namespace=dist.owner_namespace,
package=dist.package,
@@ -73,10 +74,9 @@ async def status_check(args: DistributionStatusCheckArgs, *,
task_id: int | None
dd,
allow_retries=True,
)
- except storage.AccessError as e:
+ except (distribution.DistributionError, storage.AccessError) as e:
msg = f"Failed to record distribution: {e}"
log.error(msg)
- raise RuntimeError(msg)
finally:
if args.next_schedule_seconds:
next_schedule = datetime.datetime.now(datetime.UTC) +
datetime.timedelta(
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
