Don't pass ioloop around app, only pass to BuildExecutor

Author: manics

binderhub/app.py

@@ -26,7 +26,6 @@
 from tornado.httpserver import HTTPServer
 from tornado.log import app_log
 from traitlets import (
-    Any,
     Bool,
     Bytes,
     Dict,
@@ -701,8 +700,6 @@ def _template_path_default(self):
         help="Origin to use when emitting events. Defaults to hostname of request when empty",
     )
 
-    ioloop = Any(help="Event loop to use")
-
     @staticmethod
     def add_url_prefix(prefix, handlers):
         """add a url prefix to handlers"""
@@ -730,7 +727,6 @@ def init_pycurl(self):
     def initialize(self, *args, **kwargs):
         """Load configuration settings."""
         super().initialize(*args, **kwargs)
-        self.ioloop = tornado.ioloop.IOLoop.current()
         self.load_config_file(self.config_file)
         # hook up tornado logging
         if self.debug:
@@ -843,7 +839,6 @@ def initialize(self, *args, **kwargs):
                 "auth_enabled": self.auth_enabled,
                 "event_log": self.event_log,
                 "normalized_origin": self.normalized_origin,
-                "ioloop": self.ioloop,
             }
         )
         if self.auth_enabled:
@@ -965,7 +960,7 @@ def start(self, run_loop=True):
         if self.builder_required:
             asyncio.ensure_future(self.watch_build_pods())
         if run_loop:
-            self.ioloop.start()
+            tornado.ioloop.IOLoop.current().start()
 
 
 main = BinderHub.launch_instance

binderhub/builder.py

@@ -15,6 +15,7 @@
 from prometheus_client import Counter, Gauge, Histogram
 from tornado import gen
 from tornado.httpclient import HTTPClientError
+from tornado.ioloop import IOLoop
 from tornado.iostream import StreamClosedError
 from tornado.log import app_log
 from tornado.queues import Queue
@@ -259,7 +260,7 @@ async def get(self, provider_prefix, _unescaped_spec):
             return
 
         # create a heartbeat
-        self.settings["ioloop"].spawn_callback(self.keep_alive)
+        IOLoop.current().spawn_callback(self.keep_alive)
 
         spec = spec.rstrip("/")
         key = f"{provider_prefix}:{spec}"
@@ -446,7 +447,7 @@ async def get(self, provider_prefix, _unescaped_spec):
                 git_credentials=provider.git_credentials,
                 sticky_builds=self.settings["sticky_builds"],
             )
-            build.main_loop = self.settings["ioloop"]
+            build.main_loop = IOLoop.current()
         else:
             build = BuildClass(
                 # Commented properties should be set in traitlets config
@@ -467,7 +468,7 @@ async def get(self, provider_prefix, _unescaped_spec):
                 # log_tail_lines=self.settings["log_tail_lines"],
                 git_credentials=provider.git_credentials,
                 # sticky_builds=self.settings["sticky_builds"],
-                main_loop=self.settings["ioloop"],
+                main_loop=IOLoop.current(),
             )
         self.build = build
 
@@ -492,7 +493,7 @@ def _check_result(future):
             # Start building
             submit_future = pool.submit(build.submit)
             submit_future.add_done_callback(_check_result)
-            self.settings["ioloop"].add_callback(lambda: submit_future)
+            IOLoop.current().add_callback(lambda: submit_future)
 
             log_future = None