mirror of
https://github.com/agent0ai/agent-zero.git
synced 2026-05-23 12:44:31 +00:00
d1827e6c66
Add user-configurable timezone and 12/24-hour preferences, then wire them through settings, runtime snapshots, scheduler payloads, wait handling, notifications, backups, memory, plugin metadata, and frontend formatters. Keep UTC as the boundary for absolute instants while serializing user-facing dates in the configured or browser-resolved timezone. Preserve scheduler wall-clock inputs in the selected timezone, propagate TZ into desktop/runtime process environments, and restart active desktop sessions when the runtime timezone changes. Cover the risky paths with timezone regression tests for settings normalization, auto and fixed timezone resolution, scheduler round-trips, memory timestamp conversion, and desktop timezone sync.
68 lines
2.1 KiB
Python
68 lines
2.1 KiB
Python
import asyncio
|
|
|
|
from helpers.localization import Localization
|
|
from helpers.print_style import PrintStyle
|
|
|
|
|
|
def format_remaining_time(total_seconds: float) -> str:
|
|
if total_seconds < 0:
|
|
total_seconds = 0
|
|
|
|
days, remainder = divmod(total_seconds, 86400)
|
|
hours, remainder = divmod(remainder, 3600)
|
|
minutes, seconds = divmod(remainder, 60)
|
|
|
|
days = int(days)
|
|
hours = int(hours)
|
|
minutes = int(minutes)
|
|
|
|
parts = []
|
|
if days > 0:
|
|
parts.append(f"{days}d")
|
|
if hours > 0:
|
|
parts.append(f"{hours}h")
|
|
if minutes > 0:
|
|
parts.append(f"{minutes}m")
|
|
|
|
if days > 0 or hours > 0:
|
|
if seconds >= 1:
|
|
parts.append(f"{int(seconds)}s")
|
|
elif minutes > 0:
|
|
if seconds >= 0.1:
|
|
parts.append(f"{seconds:.1f}s")
|
|
else:
|
|
parts.append(f"{total_seconds:.1f}s")
|
|
|
|
if not parts:
|
|
return "0.0s remaining"
|
|
|
|
return " ".join(parts) + " remaining"
|
|
|
|
|
|
async def managed_wait(agent, target_time, is_duration_wait, log, get_heading_callback):
|
|
|
|
while Localization.get().now() < target_time:
|
|
before_intervention = Localization.get().now()
|
|
await agent.handle_intervention()
|
|
after_intervention = Localization.get().now()
|
|
|
|
if is_duration_wait:
|
|
pause_duration = after_intervention - before_intervention
|
|
if pause_duration.total_seconds() > 1.5: # Adjust for pauses longer than the sleep cycle
|
|
target_time += pause_duration
|
|
PrintStyle.info(
|
|
f"Wait extended by {pause_duration.total_seconds():.1f}s to {Localization.get().serialize_datetime(target_time)}...",
|
|
)
|
|
|
|
current_time = Localization.get().now()
|
|
if current_time >= target_time:
|
|
break
|
|
|
|
remaining_seconds = (target_time - current_time).total_seconds()
|
|
if log:
|
|
log.update(heading=get_heading_callback(format_remaining_time(remaining_seconds)))
|
|
sleep_duration = min(1.0, remaining_seconds)
|
|
|
|
await asyncio.sleep(sleep_duration)
|
|
|
|
return target_time
|