Skip to content

Commit

Permalink
Use BaseException instead of union
Browse files Browse the repository at this point in the history
  • Loading branch information
nazywam committed Mar 26, 2024
1 parent 0d4d30b commit 6cd1d9d
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions karton/core/karton.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@
from .task import Task, TaskState
from .utils import timeout

KartonTaskException = Union[Exception, BaseException]


class Producer(KartonBase):
Expand Down Expand Up @@ -134,7 +133,7 @@ def __init__(
self._post_hooks: List[
Tuple[
Optional[str],
Callable[[Task, Optional[KartonTaskException]], None],
Callable[[Task, Optional[BaseException]], None],
]
] = []

Expand Down Expand Up @@ -266,7 +265,7 @@ def add_pre_hook(

def add_post_hook(
self,
callback: Callable[[Task, Optional[KartonTaskException]], None],
callback: Callable[[Task, Optional[BaseException]], None],
name: Optional[str] = None,
) -> None:
"""
Expand Down Expand Up @@ -295,7 +294,7 @@ def _run_pre_hooks(self) -> None:
else:
self.log.exception("Pre-hook failed")

def _run_post_hooks(self, exception: Optional[KartonTaskException]) -> None:
def _run_post_hooks(self, exception: Optional[BaseException]) -> None:
"""
Run registered postprocessing hooks
Expand Down Expand Up @@ -437,7 +436,7 @@ def _send_signaling_status_task_begin(self, task: Task) -> None:
self._send_signaling_status_task("task_begin")

def _send_signaling_status_task_end(
self, task: Task, ex: Optional[KartonTaskException]
self, task: Task, ex: Optional[BaseException]
) -> None:
"""Send a begin status signaling task.
Expand Down

0 comments on commit 6cd1d9d

Please sign in to comment.