fixed errors with logs url

This commit is contained in:
Khalim Conn-Kowlessar 2025-11-28 07:48:52 +00:00
parent c400a67bf6
commit e29e96e617

View file

@ -240,8 +240,7 @@ def build_cloudwatch_log_url(start_ms: int) -> str:
def handle_error(session, msg, e, subtask_id, status=500, start_ms=None):
# When the pipeline fails, handles error process
end_ms = int(time.time() * 1000)
cloud_logs_url = build_cloudwatch_log_url(start_ms, end_ms)
cloud_logs_url = build_cloudwatch_log_url(start_ms)
SubTaskInterface().update_subtask_status(
subtask_id=UUID(subtask_id),