diff --git a/tests/topotests/lib/bmp_collector/bmpserver b/tests/topotests/lib/bmp_collector/bmpserver.py
similarity index 95%
rename from tests/topotests/lib/bmp_collector/bmpserver
rename to tests/topotests/lib/bmp_collector/bmpserver.py
index 56d85fc74b..1f8c12cdd5 100755
--- a/tests/topotests/lib/bmp_collector/bmpserver
+++ b/tests/topotests/lib/bmp_collector/bmpserver.py
@@ -80,9 +80,7 @@ def main():
                     while len(data) > BMPMsg.MIN_LEN:
                         data = BMPMsg.dissect(data, log_file=LOG_FILE)
 
-                    timestamp_print(
-                        f"Finished dissecting data from {client_address}"
-                    )
+                    timestamp_print(f"Finished dissecting data from {client_address}")
 
             except Exception as e:
                 timestamp_print(f"{e}")
diff --git a/tests/topotests/lib/topogen.py b/tests/topotests/lib/topogen.py
index 4d7c56423e..dce83d5ef5 100644
--- a/tests/topotests/lib/topogen.py
+++ b/tests/topotests/lib/topogen.py
@@ -1296,7 +1296,7 @@ class TopoBMPCollector(TopoHost):
 
         with open(log_err, "w") as err:
             self.run(
-                "{}/bmp_collector/bmpserver -a {} -p {} {}&".format(
+                "{}/bmp_collector/bmpserver.py -a {} -p {} {}&".format(
                     CWD, self.ip, self.port, log_arg
                 ),
                 stdout=None,
@@ -1304,7 +1304,7 @@ class TopoBMPCollector(TopoHost):
             )
 
     def stop(self):
-        self.run("pkill -f bmpserver")
+        self.run("pkill -f bmpserver.py")
         return ""