diff --git a/Utils/Dataflow/016_task2es/task2es.py b/Utils/Dataflow/016_task2es/task2es.py
index b386f3774..2bf462b48 100755
--- a/Utils/Dataflow/016_task2es/task2es.py
+++ b/Utils/Dataflow/016_task2es/task2es.py
@@ -225,7 +225,7 @@ def main(args):
     if error_code == 0:
         stage.stop()
 
-    exit(exit_code)
+    exit(error_code)
 
 
 if __name__ == '__main__':