Skip to content

Commit cecc050

Browse files
committed
Fixes example image
1 parent 037c915 commit cecc050

File tree

5 files changed

+6
-1
lines changed

5 files changed

+6
-1
lines changed

examples/parallelism/lazy_threadpool_execution/README.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,11 @@ HTTP requests, reading/writing to disk, LLM API calls, etc.
1212

1313
> Note: this adapter does not support DAGs with Parallelizable and Collect functions; create an issue if you need this feature.
1414
15+
![DAG](my_functions.png)
16+
17+
The above image shows the DAG that will be executed. You can see from the structure
18+
that the DAG can be parallelized, i.e. the left most nodes can be executed in parallel.
19+
1520
When you execute `run.py`, you will output that shows:
1621

1722
1. The DAG running in parallel -- check the image against what is printed.
Loading
Loading
Binary file not shown.

examples/parallelism/lazy_threadpool_execution/run.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
start = time.time()
99
adapter = h_threadpool.FutureAdapter()
1010
dr = driver.Builder().with_modules(my_functions).with_adapters(adapter).build()
11-
dr.display_all_functions("my_funtions.png")
11+
dr.display_all_functions("my_functions.png")
1212
r = dr.execute(["s", "x", "a"])
1313
print("got return from dr")
1414
print(r)

0 commit comments

Comments
 (0)