diff --git a/atvm/watcher-service/atvm_run_watcher.py b/atvm/watcher-service/atvm_run_watcher.py
index 91a0073..75ca8a7 100644
--- a/atvm/watcher-service/atvm_run_watcher.py
+++ b/atvm/watcher-service/atvm_run_watcher.py
@@ -27,6 +27,8 @@ RUN_STATES = {
     "RUNNING",
 }
 
+LOCAL_TZ = datetime.now().astimezone().tzinfo or timezone.utc
+
 
 @dataclass
 class HostResult:
@@ -177,7 +179,7 @@ def parse_xml_timestamp(raw: Optional[str]) -> Optional[datetime]:
 
 def parse_log_timestamp(raw: str) -> Optional[datetime]:
     try:
-        return datetime.strptime(raw, "%Y-%m-%d %H:%M:%S,%f").replace(tzinfo=timezone.utc)
+        return datetime.strptime(raw, "%Y-%m-%d %H:%M:%S,%f").replace(tzinfo=LOCAL_TZ).astimezone(timezone.utc)
     except ValueError:
         return None