diff --git a/beat/backend/python/execution/loop.py b/beat/backend/python/execution/loop.py
index a67bdee6b84c5aa662421e3c0c4159a84649f8c9..399537c70a24d6cee318d13bb4745c5b66939983 100644
--- a/beat/backend/python/execution/loop.py
+++ b/beat/backend/python/execution/loop.py
@@ -214,6 +214,7 @@ class LoopExecutor(object):
             self.prefix,
             cache_root,
             input_list=self.input_list,
+            data_loaders=self.data_loaders,
         )
 
         self.message_handler = message_handler