Skip to content

Commit 06d6250

Browse files
committed
merge main with async client change
Signed-off-by: Filinto Duran <[email protected]>
1 parent 9240283 commit 06d6250

File tree

5 files changed

+17
-193
lines changed

5 files changed

+17
-193
lines changed

ext/dapr-ext-workflow/dapr/ext/workflow/aio/__init__.py

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,18 @@
1414
"""
1515

1616
from .dapr_workflow_client import DaprWorkflowClient
17+
from .async_context import AsyncWorkflowContext
18+
from .async_driver import CoroutineOrchestratorRunner
19+
from .awaitables import ActivityAwaitable, ExternalEventAwaitable, SleepAwaitable, SubOrchestratorAwaitable, WhenAnyAwaitable, WhenAllAwaitable
1720

1821
__all__ = [
22+
'ActivityAwaitable',
23+
'AsyncWorkflowContext',
24+
'CoroutineOrchestratorRunner',
25+
'ExternalEventAwaitable',
1926
'DaprWorkflowClient',
27+
'SleepAwaitable',
28+
'SubOrchestratorAwaitable',
29+
'WhenAnyAwaitable',
30+
'WhenAllAwaitable',
2031
]

ext/dapr-ext-workflow/dapr/ext/workflow/aio/async_context.py

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -158,8 +158,3 @@ def get_headers(self) -> dict[str, str] | None:
158158
@property
159159
def execution_info(self): # type: ignore[override]
160160
return getattr(self._base_ctx, '_execution_info', None)
161-
162-
163-
__all__ = [
164-
'AsyncWorkflowContext',
165-
]

ext/dapr-ext-workflow/examples/generics_interceptors_example.py

Lines changed: 0 additions & 183 deletions
This file was deleted.

ext/dapr-ext-workflow/tests/integration/dapr_test_utils.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
"""
44
Utility functions for Dapr integration/e2e tests.
55
6-
Provides helpers for starting Dapr sidecars and managing test infrastructure.
6+
Provides helpers for starting Dapr sidecars and managing test infrastructure during integratino (e2e) tests
77
"""
88

99
from __future__ import annotations

tox.ini

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,13 +16,14 @@ package = editable
1616
commands =
1717
coverage run -m unittest discover -v ./tests
1818
# ext/dapr-ext-workflow uses pytest-based tests
19+
# only workflow has e2e tests (with daprd sidecars initiated as fixtures during tests)
1920
!e2e: coverage run -a -m pytest -q -m "not e2e" ext/dapr-ext-workflow/tests
2021
e2e: coverage run -a -m pytest -q -m "e2e" ext/dapr-ext-workflow/tests
2122

22-
coverage run -a -m unittest discover -v ./ext/dapr-ext-grpc/tests
23-
coverage run -a -m unittest discover -v ./ext/dapr-ext-fastapi/tests
24-
coverage run -a -m unittest discover -v ./ext/dapr-ext-langgraph/tests
25-
coverage run -a -m unittest discover -v ./ext/flask_dapr/tests
23+
!e2e: coverage run -a -m unittest discover -v ./ext/dapr-ext-grpc/tests
24+
!e2e: coverage run -a -m unittest discover -v ./ext/dapr-ext-fastapi/tests
25+
!e2e: coverage run -a -m unittest discover -v ./ext/dapr-ext-langgraph/tests
26+
!e2e: coverage run -a -m unittest discover -v ./ext/flask_dapr/tests
2627
coverage xml
2728
commands_pre =
2829
# TODO: remove this before merging (after durable task is merged)

0 commit comments

Comments
 (0)