diff --git a/python/pipeline/dag.py b/python/pipeline/dag.py
index f73a3b51c002ddcd8d44b1f60172fde54f2075ff..15c3317f15b1870cecc2a8e00a71c47f44dec0bc 100644
--- a/python/pipeline/dag.py
+++ b/python/pipeline/dag.py
@@ -40,7 +40,7 @@ class DAGExecutor(object):
         use_multithread = yml_config.get('use_multithread', True)
         use_profile = yml_config.get('profile', False)
         channel_size = yml_config.get('channel_size', 0)
-        self._asyn_profile = yml_config.get('asgn_profile', False)
+        self._asyn_profile = yml_config.get('asyn_profile', False)
 
         if use_profile:
             _LOGGER.info("====> profiler <====")