examples: switch to newer asyncio API

julianoes · julianoes · commit 87a7aefcf326 · 2023-01-14T09:32:34.000+13:00
Available since Python 3.7.

Signed-off-by: Julian Oes &lt;julian@oes.ch&gt;
diff --git a/examples/calibration.py b/examples/calibration.py
@@ -31,5 +31,5 @@ async def run():
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/camera.py b/examples/camera.py
@@ -56,5 +56,5 @@ async def print_status(drone):
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/camera_params.py b/examples/camera_params.py
@@ -185,5 +185,5 @@ async def make_user_choose_option_range(possible_options):
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/failure_injection.py b/examples/failure_injection.py
@@ -59,5 +59,5 @@ async def run():
     await drone.param.set_param_int('SYS_FAILURE_EN', 0)
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/firmware_version.py b/examples/firmware_version.py
@@ -19,5 +19,5 @@ async def run():
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/follow_me_example.py b/examples/follow_me_example.py
@@ -64,5 +64,5 @@ async def fly_drone():
     await drone.action.land()
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(fly_drone())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/geofence.py b/examples/geofence.py
@@ -7,7 +7,7 @@
 """
 This example shows how to use the geofence plugin.
 
-Note: The behavior when your vehicle hits the geofence is NOT configured in this example. 
+Note: The behavior when your vehicle hits the geofence is NOT configured in this example.
 
 """
 
@@ -51,5 +51,5 @@ async def run():
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/gimbal.py b/examples/gimbal.py
@@ -83,6 +83,5 @@ async def print_gimbal_position(drone):
 
 
 if __name__ == "__main__":
-    # Start the main function
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/goto.py b/examples/goto.py
@@ -43,5 +43,5 @@ async def run():
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/logfile_download.py b/examples/logfile_download.py
@@ -42,4 +42,5 @@ async def get_entries(drone):
 
 
 if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/manual_control.py b/examples/manual_control.py
@@ -91,6 +91,5 @@ async def manual_controls():
 
 
 if __name__ == "__main__":
-
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(manual_controls())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/mission.py b/examples/mission.py
@@ -116,5 +116,5 @@ async def observe_is_in_air(drone, running_tasks):
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/mission_import.py b/examples/mission_import.py
@@ -24,5 +24,5 @@ async def run():
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/offboard_attitude.py b/examples/offboard_attitude.py
@@ -72,5 +72,5 @@ async def run():
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/offboard_position_ned.py b/examples/offboard_position_ned.py
@@ -71,5 +71,5 @@ async def run():
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/offboard_position_velocity_ned.py b/examples/offboard_position_velocity_ned.py
@@ -64,5 +64,5 @@ async def print_z_velocity(drone):
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/offboard_velocity_body.py b/examples/offboard_velocity_body.py
@@ -86,5 +86,5 @@ async def run():
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/offboard_velocity_ned.py b/examples/offboard_velocity_ned.py
@@ -79,5 +79,5 @@ async def run():
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/send_status_message.py b/examples/send_status_message.py
@@ -29,5 +29,5 @@ async def run():
             break
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/takeoff_and_land.py b/examples/takeoff_and_land.py
@@ -47,5 +47,5 @@ async def print_status_text(drone):
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/takeoff_and_land_keyboard_control.py b/examples/takeoff_and_land_keyboard_control.py
@@ -1,6 +1,4 @@
-"""
-Author: @woosal1337
-"""
+#!/usr/bin/env python3
 
 import asyncio
 import pygame
@@ -148,6 +146,7 @@ async def print_position(drone=drone):
 
 if __name__ == "__main__":
 
+    # TODO: use new asyncio methods
     loop = asyncio.get_event_loop()
     loop.run_until_complete(setup())
     loop.run_until_complete(main())
diff --git a/examples/telemetry.py b/examples/telemetry.py
@@ -36,8 +36,5 @@ async def print_position(drone):
 
 
 if __name__ == "__main__":
-    # Start the main function
-    asyncio.ensure_future(run())
-
-    # Runs the event loop until the program is canceled with e.g. CTRL-C
-    asyncio.get_event_loop().run_forever()
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/telemetry_flight_mode.py b/examples/telemetry_flight_mode.py
@@ -19,5 +19,5 @@ async def print_flight_mode():
 
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(print_flight_mode())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/telemetry_is_armed_is_in_air.py b/examples/telemetry_is_armed_is_in_air.py
@@ -23,8 +23,5 @@ async def print_is_in_air(drone):
 
 
 if __name__ == "__main__":
-    # Start the main function
-    asyncio.ensure_future(run())
-
-    # Runs the event loop until the program is canceled with e.g. CTRL-C
-    asyncio.get_event_loop().run_forever()
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/telemetry_takeoff_and_land.py b/examples/telemetry_takeoff_and_land.py
@@ -108,4 +108,5 @@ async def observe_is_in_air(drone, running_tasks):
 
 
 if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/transponder.py b/examples/transponder.py
@@ -9,7 +9,7 @@ async def run():
     drone = System()
     #await drone.connect(system_address="udp://:14540")
     await drone.connect()
-    
+
     # Start the tasks
     asyncio.ensure_future(print_transponders(drone))
 
@@ -19,8 +19,5 @@ async def print_transponders(drone):
 
 
 if __name__ == "__main__":
-    # Start the main function
-    asyncio.ensure_future(run())
-
-    # Runs the event loop until the program is canceled with e.g. CTRL-C
-    asyncio.get_event_loop().run_forever()
+    # Run the asyncio loop
+    asyncio.run(run())
diff --git a/examples/tune.py b/examples/tune.py
@@ -64,5 +64,5 @@ async def run():
     print("Tune played")
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(run())
+    # Run the asyncio loop
+    asyncio.run(run())
