From 5da4f6c6d0bcccbc9d000259fb8b2281e1b7c514 Mon Sep 17 00:00:00 2001 From: Aymen Alsaadi <27039262+AymenFJA@users.noreply.github.com> Date: Fri, 14 Nov 2025 11:52:05 -0500 Subject: [PATCH 1/2] fix how to init the execution backend --- README.md | 4 ++-- docs/getting-started/quick-start.md | 12 ++++++------ docs/pipelines/pre_built-pipelines.md | 2 +- 3 files changed, 9 insertions(+), 9 deletions(-) diff --git a/README.md b/README.md index 48c45df..46a3613 100644 --- a/README.md +++ b/README.md @@ -20,7 +20,7 @@ pip install . import asyncio from typing import Dict, Any, Optional, List -from radical.asyncflow import RadicalExecutionBackend +from radical.asyncflow import await RadicalExecutionBackend from impress import PipelineSetup from impress import ImpressManager @@ -36,7 +36,7 @@ async def impress_protein_bind() -> None: pipelines based on protein quality degradation. """ manager: ImpressManager = ImpressManager( - execution_backend=RadicalExecutionBackend( + execution_backend = await RadicalExecutionBackend( {'gpus':2, 'cores': 32, 'runtime' : 13 * 60, diff --git a/docs/getting-started/quick-start.md b/docs/getting-started/quick-start.md index 8f16d74..45d62a0 100644 --- a/docs/getting-started/quick-start.md +++ b/docs/getting-started/quick-start.md @@ -28,7 +28,7 @@ from impress import PipelineSetup from impress import ImpressBasePipeline from impress import ImpressManager -from radical.asyncflow import RadicalExecutionBackend +from radical.asyncflow import await RadicalExecutionBackend ``` @@ -36,7 +36,7 @@ We use: asyncio — Python’s built-in asynchronous library. -RadicalExecutionBackend — runs tasks in parallel. +await RadicalExecutionBackend — runs tasks in parallel. ImpressBasePipeline — base class for defining a pipeline. @@ -115,7 +115,7 @@ We now create a function that starts N pipelines at once. ```python async def run(): manager = ImpressManager( - execution_backend=RadicalExecutionBackend({'resource': 'local.localhost'}) + execution_backend = await RadicalExecutionBackend({'resource': 'local.localhost'}) ) # start 3 pipelines in parallel and wait for them to finish @@ -129,7 +129,7 @@ async def run(): Here: -We initialize an ImpressManager with a RadicalExecutionBackend to enable parallel task execution. +We initialize an ImpressManager with a await RadicalExecutionBackend to enable parallel task execution. We call start() and provide a list of pipeline setups, each with a unique name (p1, p2, p3) and our ProteinPipeline class. @@ -155,7 +155,7 @@ from impress import PipelineSetup from impress import ImpressBasePipeline from impress import ImpressManager -from radical.asyncflow import RadicalExecutionBackend +from radical.asyncflow import await RadicalExecutionBackend class ProteinPipeline(ImpressBasePipeline): @@ -186,7 +186,7 @@ class ProteinPipeline(ImpressBasePipeline): async def run_pipeline(): manager = ImpressManager( - execution_backend=RadicalExecutionBackend({'resource': 'local.localhost'}) + execution_backend = await RadicalExecutionBackend({'resource': 'local.localhost'}) ) await manager.start( diff --git a/docs/pipelines/pre_built-pipelines.md b/docs/pipelines/pre_built-pipelines.md index b9894db..da92c3a 100644 --- a/docs/pipelines/pre_built-pipelines.md +++ b/docs/pipelines/pre_built-pipelines.md @@ -136,7 +136,7 @@ async def adaptive_decision(pipeline: ProteinBindingPipeline) -> Optional[Dict[s ```python async def impress_protein_bind() -> None: manager: ImpressManager = ImpressManager( - execution_backend=RadicalExecutionBackend({ + execution_backend = await RadicalExecutionBackend({ 'gpus': 2, # GPU allocation per pipeline 'cores': 32, # CPU cores per pipeline 'runtime': 13 * 60, # 13 hours maximum runtime From b1b1f6cbbe888174935004ce35593e6d49fe6d57 Mon Sep 17 00:00:00 2001 From: Aymen Alsaadi <27039262+AymenFJA@users.noreply.github.com> Date: Fri, 14 Nov 2025 12:00:38 -0500 Subject: [PATCH 2/2] typo --- README.md | 2 +- docs/getting-started/quick-start.md | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/README.md b/README.md index 46a3613..1e0e3a5 100644 --- a/README.md +++ b/README.md @@ -20,7 +20,7 @@ pip install . import asyncio from typing import Dict, Any, Optional, List -from radical.asyncflow import await RadicalExecutionBackend +from radical.asyncflow import RadicalExecutionBackend from impress import PipelineSetup from impress import ImpressManager diff --git a/docs/getting-started/quick-start.md b/docs/getting-started/quick-start.md index 45d62a0..ce937c2 100644 --- a/docs/getting-started/quick-start.md +++ b/docs/getting-started/quick-start.md @@ -28,7 +28,7 @@ from impress import PipelineSetup from impress import ImpressBasePipeline from impress import ImpressManager -from radical.asyncflow import await RadicalExecutionBackend +from radical.asyncflow import RadicalExecutionBackend ``` @@ -155,7 +155,7 @@ from impress import PipelineSetup from impress import ImpressBasePipeline from impress import ImpressManager -from radical.asyncflow import await RadicalExecutionBackend +from radical.asyncflow import RadicalExecutionBackend class ProteinPipeline(ImpressBasePipeline):