From df3616dd03c181065145cde50cd22bc38e6c2b5e Mon Sep 17 00:00:00 2001 From: tcely Date: Thu, 3 Jul 2025 18:13:34 -0400 Subject: [PATCH] Populate the new `TaskHistory` fields from huey --- tubesync/common/huey.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/tubesync/common/huey.py b/tubesync/common/huey.py index 014104f2..6f34b5e9 100644 --- a/tubesync/common/huey.py +++ b/tubesync/common/huey.py @@ -278,14 +278,15 @@ def historical_task(signal_name, task_obj, exception_obj=None, /, *, huey=None): th.verbose_name = f'{th.name} with: {model_instance.key}' if hasattr(model_instance, 'name'): th.verbose_name += f' / {model_instance.name}' - th.end_at = signal_dt - if signal_name == signals.SIGNAL_SCHEDULED: + elif signal_name == signals.SIGNAL_SCHEDULED: if huey.utc: - th.end_at = task_obj.eta.replace(tzinfo=datetime.UTC) + th.scheduled_at = task_obj.eta.replace(tzinfo=datetime.UTC) else: # this path is unlikely - th.end_at = timestamp_to_datetime( + th.scheduled_at = timestamp_to_datetime( datetime_to_timestamp(task_obj.eta, integer=False), ).astimezone(tz=datetime.UTC) + th.end_at = signal_dt + th.elapsed = history['elapsed'] th.save() # Registration of shared signal handlers