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 24f891be Fix scheduling bug in distribution status check
24f891be is described below
commit 24f891bea58931042d7cd0ce8831ce783a55a851
Author: Alastair McFarlane <[email protected]>
AuthorDate: Mon Feb 16 15:38:46 2026 +0000
Fix scheduling bug in distribution status check
---
atr/tasks/distribution.py | 15 ++++++---------
1 file changed, 6 insertions(+), 9 deletions(-)
diff --git a/atr/tasks/distribution.py b/atr/tasks/distribution.py
index 2ca45f6e..c1e72515 100644
--- a/atr/tasks/distribution.py
+++ b/atr/tasks/distribution.py
@@ -77,15 +77,12 @@ async def status_check(args: DistributionStatusCheckArgs,
*, task_id: int | None
except (distribution.DistributionError, storage.AccessError) as e:
msg = f"Failed to record distribution: {e}"
log.error(msg)
- finally:
- if args.next_schedule_seconds:
- next_schedule = datetime.datetime.now(datetime.UTC) +
datetime.timedelta(
- seconds=args.next_schedule_seconds
- )
- await tasks.distribution_status_check(args.asf_uid,
schedule=next_schedule, schedule_next=True)
- log.info(
- f"Scheduled next workflow status update for:
{next_schedule.strftime('%Y-%m-%d %H:%M:%S')}",
- )
+ if args.next_schedule_seconds:
+ next_schedule = datetime.datetime.now(datetime.UTC) +
datetime.timedelta(seconds=args.next_schedule_seconds)
+ await tasks.distribution_status_check(args.asf_uid,
schedule=next_schedule, schedule_next=True)
+ log.info(
+ f"Scheduled next workflow status update for:
{next_schedule.strftime('%Y-%m-%d %H:%M:%S')}",
+ )
return results.DistributionStatusCheck(
kind="distribution_status",
)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
