Populate the new TaskHistory fields from huey

This commit is contained in:
tcely authored and GitHub committed 2025-07-03 18:13:34 -04:00
1 parent d195f43942
commit df3616dd03
1 file changed
+5 -4
+5 -4
View File
@@ -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