The code (here)[] won't run as the async call cannot happen outside of a function. This code should be complete:
#!/usr/bin/env python3
import os
import asyncio
from radical.asyncflow import WorkflowEngine
from radical.asyncflow import RadicalExecutionBackend
from rose.al.active_learner import SequentialActiveLearner
async def main():
engine = await RadicalExecutionBackend(
{'runtime': 30,
'resource': 'local.localhost'})
asyncflow = await WorkflowEngine.create(engine)
acl = SequentialActiveLearner(asyncflow)
[...]
asyncio.run(main())
I should add that none of the examples under examples/ runs out of the box, mostly because of something like this:
radical.asyncflow.errors.DependencyFailureError: Cannot execute 'check_mse' due to dependency failure
which seems not to resolve the (existing) python scripts.
The code (here)[] won't run as the async call cannot happen outside of a function. This code should be complete:
I should add that none of the examples under
examples/runs out of the box, mostly because of something like this:radical.asyncflow.errors.DependencyFailureError: Cannot execute 'check_mse' due to dependency failurewhich seems not to resolve the (existing) python scripts.