diff --git a/rclpy/test/test_executor.py b/rclpy/test/test_executor.py
index bfdea0c7d..4d66bad8c 100644
--- a/rclpy/test/test_executor.py
+++ b/rclpy/test/test_executor.py
@@ -399,8 +399,8 @@ def test_coroutine_exception_after_await(self):
                 executor = cls(context=self.context)
                 executor.add_node(self.node)
 
-                first_fut = executor.create_future()
-                second_fut = executor.create_future()
+                first_fut = Future(executor=executor)
+                second_fut = Future(executor=executor)
 
                 async def coro_that_raises():
                     first_fut.set_result(None)
@@ -427,9 +427,9 @@ def test_cancel_task_while_awaiting_future(self):
                 executor = cls(context=self.context)
                 executor.add_node(self.node)
 
-                first_fut = executor.create_future()
-                second_fut = executor.create_future()
-                third_fut = executor.create_future()
+                first_fut = Future(executor=executor)
+                second_fut = Future(executor=executor)
+                third_fut = Future(executor=executor)
 
                 async def coro():
                     first_fut.set_result(None)
@@ -458,7 +458,7 @@ def test_await_already_completed_future(self):
                 executor = cls(context=self.context)
                 executor.add_node(self.node)
 
-                fut = executor.create_future()
+                fut = Future(executor=executor)
                 fut.set_result('done')  # complete before the task runs
 
                 async def coro():
@@ -470,16 +470,6 @@ async def coro():
                 self.assertTrue(task.done())
                 self.assertEqual('done', task.result())
 
-    def test_create_task_during_spin(self):
-        self.assertIsNotNone(self.node.handle)
-        for cls in [SingleThreadedExecutor, EventsExecutor]:
-            with self.subTest(cls=cls):
-                executor = cls(context=self.context)
-                executor.add_node(self.node)
-
-        self.assertTrue(future.done())
-        self.assertEqual('Sentinel Result', future.result())
-
     def test_global_executor_completes_async_task(self):
         self.assertIsNotNone(self.node.handle)