diff --git a/tests/system-test/0-others/udfpy_main.py b/tests/system-test/0-others/udfpy_main.py
index e76795ac28..2dd97ea2c5 100644
--- a/tests/system-test/0-others/udfpy_main.py
+++ b/tests/system-test/0-others/udfpy_main.py
@@ -20,6 +20,7 @@ from util.sqlset import *
 
 import random
 import os
+import subprocess
 
 
 class PerfDB:
@@ -414,8 +415,17 @@ class TDTestCase:
         tdSql.execute(sql)
         tdLog.info(sql)
 
+    def install_taospy(self):
+        tdLog.info("install taospyudf...")
+        packs = ["taospyudf"]
+        for pack in packs:
+            subprocess.check_call([sys.executable, '-m', 'pip', 'install', pack])
+        tdLog.info("install taospyudf successfully.")
+
     # run
     def run(self):
+        self.install_taospy()
+
         # var
         stable = "meters"
         tbname = "d"