Skip to content

Commit 3b2d7d3

Browse files
Fix ruff issues
1 parent 4f76e46 commit 3b2d7d3

2 files changed

Lines changed: 12 additions & 2 deletions

File tree

tilebox-datasets/tilebox/datasets/progress.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,11 @@
33
from types import TracebackType
44
from typing import Any
55

6+
try:
7+
from typing import Self # ty: ignore[unresolved-import]
8+
except ImportError: # Self is only available in Python 3.11+
9+
from typing_extensions import Self
10+
611
from tqdm.auto import tqdm
712

813
from tilebox.datasets.query.time_interval import TimeInterval
@@ -42,7 +47,7 @@ def __init__(
4247
self._actual_start_time = actual_start_time
4348
self._total_data_points = 0
4449

45-
def __enter__(self) -> "TimeIntervalProgressBar":
50+
def __enter__(self) -> Self:
4651
self._progress_bar = tqdm(
4752
bar_format="{l_bar}{bar}[{elapsed}<{remaining}{postfix}]",
4853
total=self._calc_progress_seconds(self._interval.end),

tilebox-workflows/tilebox/workflows/runner/task_runner.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,11 @@
1919
from uuid import UUID
2020
from warnings import warn
2121

22+
try:
23+
from typing import Self # ty: ignore[unresolved-import]
24+
except ImportError: # Self is only available in Python 3.11+
25+
from typing_extensions import Self
26+
2227
from loguru import logger
2328
from opentelemetry.trace.status import StatusCode
2429
from tenacity import retry, retry_if_exception_type, stop_when_event_set, wait_random_exponential
@@ -260,7 +265,7 @@ def sleep(self, seconds: float) -> None:
260265
"""Sleep for a given number of seconds, or until an interrupt signal is received."""
261266
self._interrupted.wait(seconds)
262267

263-
def __enter__(self) -> "_GracefulShutdown":
268+
def __enter__(self) -> Self:
264269
"""Enter a graceful shutdown context. Intercepts SIGTERM and SIGINT signals and delays them by a grace period."""
265270
self._original_sigterm = signal.signal(signal.SIGTERM, self._external_interrupt_handler)
266271
self._original_sigint = signal.signal(signal.SIGINT, self._external_interrupt_handler)

0 commit comments

Comments
 (0)