_stream.py: Stop using a 'RUNNING' event to know the state of the scheduler

The stream is itself calling the `run` method on the scheduler, we don't
need another indirection

1 files changed, 0 insertions, 7 deletions

diff --git a/src/buildstream/_scheduler/scheduler.py b/src/buildstream/_scheduler/scheduler.py
index 41ff1189f..0c94fd376 100644
--- a/src/buildstream/_scheduler/scheduler.py
+++ b/src/buildstream/_scheduler/scheduler.py
@@ -58,7 +58,6 @@ class NotificationType(FastEnum):
     TICK = "tick"
     TERMINATE = "terminate"
     QUIT = "quit"
-    RUNNING = "running"
     SUSPEND = "suspend"
     UNSUSPEND = "unsuspend"
 
@@ -176,9 +175,6 @@ class Scheduler:
         self.loop = asyncio.new_event_loop()
         asyncio.set_event_loop(self.loop)
 
-        # Notify that the loop has been created
-        self._notify(Notification(NotificationType.RUNNING))
-
         # Add timeouts
         self.loop.call_later(1, self._tick)
 
@@ -214,9 +210,6 @@ class Scheduler:
         failed = any(queue.any_failed_elements() for queue in self.queues)
         self.loop = None
 
-        # Notify that the loop has been reset
-        self._notify(Notification(NotificationType.RUNNING))
-
         if failed:
             status = SchedStatus.ERROR
         elif self.terminated: