bug fix, write operations failed to start

diematic_server/diematicd.py

@@ -25,6 +25,7 @@
 from daemon import pidfile
 from aiohttp import web
 import asyncio
+import concurrent.futures
 
 from webserver import DiematicWebRequestHandler
 
@@ -131,16 +132,15 @@ def _get_context(self):
             self.context.app = self
 
             self.pidfile_timeout = 3
-            # self._open_streams_from_app_stream_paths()
             return self.context
 
-    # def _get_executor(self):
-    #     """ create the executor pool or return if already created """
-    #     try:
-    #         return self.executor
-    #     except AttributeError:
-    #         self.executor = concurrent.futures.ThreadPoolExecutor(max_workers=1)
-    #         return self.executor
+    def _get_executor(self):
+        """ create the executor pool or return if already created """
+        try:
+            return self.executor
+        except AttributeError:
+            self.executor = concurrent.futures.ThreadPoolExecutor(max_workers=1)
+            return self.executor
 
     def _value_writer(self):
         """ consumes a job writing to the boiler """

diematic_server/webserver.py

@@ -160,6 +160,7 @@ async def set_param(request):
 		value = jsoninput['value']
 		mainapp = request.app["mainapp"]
 		mainapp.MyBoiler.set_write_pending(param_name, value)
+		mainapp.check_pending_writes()
 		return web.Response()
 
 	@routes.post('/diematic/parameters/{paramName}/resume')