|
|
|
@ -12,14 +12,10 @@ from .channel import Channel
|
|
|
|
|
if TYPE_CHECKING:
|
|
|
|
|
from typing import Container # pyright: ignore[reportShadowedImports]
|
|
|
|
|
|
|
|
|
|
pass
|
|
|
|
|
|
|
|
|
|
class UnexpectedMessageWithType(Exception):
|
|
|
|
|
"""A message was received that is not part of the current workflow.
|
|
|
|
|
|
|
|
|
|
Utility exception to inform the session handler that the current workflow
|
|
|
|
|
should be aborted and a new one started as if `msg` was the first message.
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
class UnexpectedMessageWithType(Exception):
|
|
|
|
|
def __init__(self, msg: MessageWithType) -> None:
|
|
|
|
|
super().__init__()
|
|
|
|
|
self.msg = msg
|
|
|
|
|