Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion quest_test/test_external_actions.py
Original file line number Diff line number Diff line change
Expand Up @@ -334,7 +334,8 @@ async def player_workflow():
await historian.record_external_event('chat', 'p1', 'put', 'bye')

result = await workflow
assert result == [('p1', 'hello'), ('p2', 'hi'), ('p1', 'bye')]
assert result[-1] == ('p1', 'bye')
assert set(result[:2]) == {('p1', 'hello'), ('p2', 'hi')}

# After removing p1 -> when p1 tries to send message, it should raise KeyError
# with pytest.raises(KeyError):
Expand Down
3 changes: 2 additions & 1 deletion src/quest/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,8 @@

from .context import these
from .external import state, queue, identity_queue, event
from .historian import Historian, suspendable
from .historian import Historian
from .historian_context import suspendable
from .history import History
from .manager import WorkflowManager, WorkflowFactory
from .manager_wrappers import alias
Expand Down
4 changes: 3 additions & 1 deletion src/quest/external.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,9 @@
import uuid
from typing import TypeVar, Generic

from .historian import Historian, find_historian, SUSPENDED, wrap_methods_as_historian_events
from .historian import Historian
from .historian_context import find_historian, SUSPENDED
from .historian_resources import wrap_methods_as_historian_events


#
Expand Down
Loading
Loading