Fixes example image

DAGWorks-Inc · Jan 2, 2025 · cecc050 · cecc050
1 parent 037c915
commit cecc050
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 1 deletion.
diff --git a/examples/parallelism/lazy_threadpool_execution/README.md b/examples/parallelism/lazy_threadpool_execution/README.md
@@ -12,6 +12,11 @@ HTTP requests, reading/writing to disk, LLM API calls, etc.
 
 > Note: this adapter does not support DAGs with Parallelizable and Collect functions; create an issue if you need this feature.
 
+![DAG](my_functions.png)
+
+The above image shows the DAG that will be executed. You can see from the structure
+that the DAG can be parallelized, i.e. the left most nodes can be executed in parallel.
+
 When you execute `run.py`, you will output that shows:
 
 1. The DAG running in parallel -- check the image against what is printed.

diff --git a/examples/parallelism/lazy_threadpool_execution/my_functions.png b/examples/parallelism/lazy_threadpool_execution/my_functions.png
diff --git a/examples/parallelism/lazy_threadpool_execution/my_functions_async.png b/examples/parallelism/lazy_threadpool_execution/my_functions_async.png
diff --git a/examples/parallelism/lazy_threadpool_execution/my_funtions.png b/examples/parallelism/lazy_threadpool_execution/my_funtions.png
diff --git a/examples/parallelism/lazy_threadpool_execution/run.py b/examples/parallelism/lazy_threadpool_execution/run.py
@@ -8,7 +8,7 @@
 start = time.time()
 adapter = h_threadpool.FutureAdapter()
 dr = driver.Builder().with_modules(my_functions).with_adapters(adapter).build()
-dr.display_all_functions("my_funtions.png")
+dr.display_all_functions("my_functions.png")
 r = dr.execute(["s", "x", "a"])
 print("got return from dr")
 print(r)