Skip to content

Commit 14544fa

Browse files
committed
Log before forcing timeout exit
1 parent ee0c21a commit 14544fa

1 file changed

Lines changed: 9 additions & 1 deletion

File tree

tasktiger/timeouts.py

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,15 @@ def __init__(self, timeout: float) -> None:
5050

5151
def handle_death_penalty(self, signum: int, frame: Any) -> None:
5252
if self.retries >= 3:
53-
os._exit(1)
53+
# Avoid logging locks because this runs in a signal handler.
54+
try:
55+
os.write(
56+
2,
57+
b"Job timeout did not stop task after 3 attempts; "
58+
b"exiting worker.\n",
59+
)
60+
finally:
61+
os._exit(1)
5462

5563
self.retries += 1
5664
raise JobTimeoutException(

0 commit comments

Comments
 (0)