remove/cleanup

Signed-off-by: Filinto Duran <[email protected]>

Author: filintod

examples/workflow-async/simple.py

@@ -11,8 +11,8 @@
 See the specific language governing permissions and
 limitations under the License.
 """
-import json
 
+import json
 from datetime import timedelta
 from time import sleep
 
@@ -72,7 +72,14 @@ async def hello_world_wf(ctx: AsyncWorkflowContext, wf_input):
     if first == event_1:
         result_5 = await ctx.call_activity(hello_act, input=100)
         result_6 = await ctx.call_activity(hello_act, input=1000)
-        return dict(result_1=result_1, result_2=result_2, result_3=result_3, result_4=result_4, result_5=result_5, result_6=result_6)
+        return dict(
+            result_1=result_1,
+            result_2=result_2,
+            result_3=result_3,
+            result_4=result_4,
+            result_5=result_5,
+            result_6=result_6,
+        )
     return 'Timeout'
 
 
@@ -137,9 +144,14 @@ def main():
         print('Workflow failed with status ', wf_state.runtime_status)
         exit(1)
     output = json.loads(wf_state.serialized_output)
-    if (output["result_1"] != 'Activity returned 1' or output["result_2"] != 'Activity returned 10' or
-            output["result_3"] != 'Activity returned 2' or output["result_4"] != 'ok' or
-            output["result_5"] != 'Activity returned 100' or output["result_6"] != 'Activity returned 1000'):
+    if (
+        output['result_1'] != 'Activity returned 1'
+        or output['result_2'] != 'Activity returned 10'
+        or output['result_3'] != 'Activity returned 2'
+        or output['result_4'] != 'ok'
+        or output['result_5'] != 'Activity returned 100'
+        or output['result_6'] != 'Activity returned 1000'
+    ):
         print('Workflow result is incorrect!')
         exit(1)
 

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

@@ -13,7 +13,6 @@
 
 from __future__ import annotations
 
-from collections.abc import Iterable
 from typing import Any, Callable
 
 from durabletask import task
@@ -109,67 +108,3 @@ class WhenAllAwaitable(_DTWhenAllAwaitable):
 
 class WhenAnyAwaitable(_DTWhenAnyAwaitable):
     pass
-    # def __init__(self, tasks_like: Iterable[AwaitableBase | task.Task]):
-    #     self._tasks_like = list(tasks_like)
-    #
-    # def _to_task(self) -> task.Task:
-    #     underlying: list[task.Task] = []
-    #     for a in self._tasks_like:
-    #         if isinstance(a, AwaitableBase):
-    #             underlying.append(a._to_task())  # type: ignore[attr-defined]
-    #         elif isinstance(a, task.Task):
-    #             underlying.append(a)
-    #         else:
-    #             raise TypeError('when_any expects AwaitableBase or durabletask.task.Task')
-    #     return task.when_any(underlying)
-# class WhenAnyAwaitable(AwaitableBase):
-#     def __init__(self, tasks_like: Iterable[AwaitableBase | task.Task]):
-#         # Defer conversion; unit tests create awaitables with fakes lacking create_timer()
-#         self._tasks_like: list[AwaitableBase | task.Task] = list(tasks_like)
-
-#     def _to_task(self) -> task.Task:
-#         underlying: list[task.Task] = []
-#         for a in self._tasks_like:
-#             if isinstance(a, AwaitableBase):
-#                 underlying.append(a._to_task())  # type: ignore[attr-defined]
-#             elif isinstance(a, task.Task):
-#                 underlying.append(a)
-#             else:
-#                 raise TypeError('when_any expects AwaitableBase or durabletask.task.Task')
-#         return task.when_any(underlying)
-
-#     def __await__(self):
-#         when_any_task = self._to_task()
-#         completed = yield when_any_task
-
-#         # Tests sometimes send sentinels (non-Task). Pass through in that case.
-#         if not isinstance(completed, task.Task):
-#             return completed
-
-#         # Map completed back to original for identity checks if needed
-#         underlying: list[task.Task] = []
-#         for a in self._tasks_like:
-#             if isinstance(a, AwaitableBase):
-#                 underlying.append(a._to_task())  # type: ignore[attr-defined]
-#             elif isinstance(a, task.Task):
-#                 underlying.append(a)
-
-#         class _CompletedProxy:
-#             __slots__ = ('_original', '_completed')
-
-#             def __init__(self, original: Any, completed_obj: Any):
-#                 self._original = original
-#                 self._completed = completed_obj
-
-#             def __eq__(self, other: object) -> bool:
-#                 return other is self._original
-
-#             def get_result(self) -> Any:
-#                 if hasattr(self._completed, 'get_result') and callable(self._completed.get_result):
-#                     return self._completed.get_result()
-#                 return getattr(self._completed, 'result', None)
-
-#         for original, under in zip(self._tasks_like, underlying, strict=False):
-#             if completed == under:
-#                 return _CompletedProxy(original, completed)
-#         return _CompletedProxy(self._tasks_like[0], completed)