radical.asyncflow.backends.execution.concurrent¶
ConcurrentExecutionBackend ¶
ConcurrentExecutionBackend(executor: Executor)
Bases: BaseExecutionBackend
Simple async-only concurrent execution backend.
Source code in doc_env/lib/python3.13/site-packages/radical/asyncflow/backends/execution/concurrent.py
16 17 18 19 20 21 22 23 24 25 |
|
__await__ ¶
__await__()
Make backend awaitable.
Source code in doc_env/lib/python3.13/site-packages/radical/asyncflow/backends/execution/concurrent.py
27 28 29 |
|
submit_tasks async
¶
submit_tasks(tasks: list[dict[str, Any]]) -> list[Task]
Submit tasks for execution.
Source code in doc_env/lib/python3.13/site-packages/radical/asyncflow/backends/execution/concurrent.py
122 123 124 125 126 127 128 129 130 131 132 133 |
|
cancel_task async
¶
cancel_task(uid: str) -> bool
Cancel a task by its UID.
Parameters:
Name | Type | Description | Default |
---|---|---|---|
uid | str | The UID of the task to cancel. | required |
Returns:
Name | Type | Description |
---|---|---|
bool | bool | True if the task was found and cancellation was attempted, False otherwise. |
Source code in doc_env/lib/python3.13/site-packages/radical/asyncflow/backends/execution/concurrent.py
135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 |
|
cancel_all_tasks async
¶
cancel_all_tasks() -> int
Cancel all running tasks.
Source code in doc_env/lib/python3.13/site-packages/radical/asyncflow/backends/execution/concurrent.py
153 154 155 156 157 158 159 160 161 |
|
shutdown async
¶
shutdown() -> None
Shutdown the executor.
Source code in doc_env/lib/python3.13/site-packages/radical/asyncflow/backends/execution/concurrent.py
163 164 165 166 167 |
|
__aenter__ async
¶
__aenter__()
Async context manager entry.
Source code in doc_env/lib/python3.13/site-packages/radical/asyncflow/backends/execution/concurrent.py
186 187 188 189 190 |
|
__aexit__ async
¶
__aexit__(exc_type, exc_val, exc_tb)
Async context manager exit.
Source code in doc_env/lib/python3.13/site-packages/radical/asyncflow/backends/execution/concurrent.py
192 193 194 |
|
create async
classmethod
¶
create(executor: Executor)
Alternative factory method for creating initialized backend.
Parameters:
Name | Type | Description | Default |
---|---|---|---|
executor | Executor | A concurrent.Executor instance (ThreadPoolExecutor or ProcessPoolExecutor). | required |
Returns:
Type | Description |
---|---|
Fully initialized ConcurrentExecutionBackend instance. |
Source code in doc_env/lib/python3.13/site-packages/radical/asyncflow/backends/execution/concurrent.py
196 197 198 199 200 201 202 203 204 205 206 207 208 |
|