Traceback (most recent call last):


 "/srv/homeassistant/lib/python3.6/site-packages/aiohttp/web_protocol.py", line 418, in start

resp = await task


 "/srv/homeassistant/lib/python3.6/site-packages/aiohttp/web_app.py", line 458, in _handle

resp = await handler(request)


 "/srv/homeassistant/lib/python3.6/site-packages/aiohttp/web_middlewares.py", line 119, in impl

return await handler(request)


 "/srv/homeassistant/lib/python3.6/site-packages/homeassistant/components/http/real_ip.py", line 33, in real_ip_middleware

return await handler(request)


 "/srv/homeassistant/lib/python3.6/site-packages/homeassistant/components/http/ban.py", line 68, in ban_middleware

return await handler(request)


 "/srv/homeassistant/lib/python3.6/site-packages/homeassistant/components/http/auth.py", line 216, in auth_middleware

return await handler(request)


 "/srv/homeassistant/lib/python3.6/site-packages/homeassistant/components/http/view.py", line 115, in handle

result = await result


 "/srv/homeassistant/lib/python3.6/site-packages/homeassistant/components/camera/__init__.py", line 468, in get

return await self.handle(request, camera)


 "/srv/homeassistant/lib/python3.6/site-packages/homeassistant/components/camera/__init__.py", line 504, in handle

return await camera.handle_async_mjpeg_stream(request)


 "/srv/homeassistant/lib/python3.6/site-packages/homeassistant/components/yi/camera.py", line 147, in handle_async_mjpeg_stream

await stream.close()


 "/srv/homeassistant/lib/python3.6/site-packages/haffmpeg/core.py", line 158, in close

await self._loop.run_in_executor(None, _close)


 "/usr/lib/python3.6/concurrent/futures/thread.py", line 56, in run

result = self.fn(*self.args, **self.kwargs)


 "/srv/homeassistant/lib/python3.6/site-packages/haffmpeg/core.py", line 153, in _close

self._proc.stdin.write(b"q")
BrokenPipeError: [Errno 32] Broken pipe

Traceback (most recent call last):


 "/home/wjk68/.local/lib/python3.5/site-packages/tornado/gen.py", line 849, in callback

result_list.append(f.result())


 "/usr/local/intel-17/openmpi-2_0_1/python/3.5.1/lib/python3.5/asyncio/futures.py", line 274, in result

raise self._exception


 "/home/wjk68/.local/lib/python3.5/site-packages/tornado/gen.py", line 1107, in run

yielded = self.gen.throw(*exc_info)


 "/home/wjk68/.local/lib/python3.5/site-packages/distributed/deploy/local.py", line 203, in _start_worker

yield w._start()


 "/home/wjk68/.local/lib/python3.5/site-packages/tornado/gen.py", line 1099, in run

value = future.result()


 "/usr/local/intel-17/openmpi-2_0_1/python/3.5.1/lib/python3.5/asyncio/futures.py", line 274, in result

raise self._exception


 "/home/wjk68/.local/lib/python3.5/site-packages/tornado/gen.py", line 1107, in run

yielded = self.gen.throw(*exc_info)


 "/home/wjk68/.local/lib/python3.5/site-packages/distributed/nanny.py", line 156, in _start

response = yield self.instantiate()


 "/home/wjk68/.local/lib/python3.5/site-packages/tornado/gen.py", line 1099, in run

value = future.result()


 "/usr/local/intel-17/openmpi-2_0_1/python/3.5.1/lib/python3.5/asyncio/futures.py", line 274, in result

raise self._exception


 "/home/wjk68/.local/lib/python3.5/site-packages/tornado/gen.py", line 1107, in run

yielded = self.gen.throw(*exc_info)


 "/home/wjk68/.local/lib/python3.5/site-packages/distributed/nanny.py", line 224, in instantiate

self.process.start()


 "/home/wjk68/.local/lib/python3.5/site-packages/tornado/gen.py", line 1099, in run

value = future.result()


 "/usr/local/intel-17/openmpi-2_0_1/python/3.5.1/lib/python3.5/asyncio/futures.py", line 274, in result

raise self._exception


 "/home/wjk68/.local/lib/python3.5/site-packages/tornado/gen.py", line 315, in wrapper

yielded = next(result)


 "/home/wjk68/.local/lib/python3.5/site-packages/distributed/nanny.py", line 347, in start

self.init_result_q = init_q = mp_context.Queue()


 "/usr/local/intel-17/openmpi-2_0_1/python/3.5.1/lib/python3.5/multiprocessing/context.py", line 101, in Queue

return Queue(maxsize, ctx=self.get_context())


 "/usr/local/intel-17/openmpi-2_0_1/python/3.5.1/lib/python3.5/multiprocessing/queues.py", line 42, in __init__

self._rlock = ctx.Lock()


 "/usr/local/intel-17/openmpi-2_0_1/python/3.5.1/lib/python3.5/multiprocessing/context.py", line 66, in Lock

return Lock(ctx=self.get_context())


 "/usr/local/intel-17/openmpi-2_0_1/python/3.5.1/lib/python3.5/multiprocessing/synchronize.py", line 163, in __init__

SemLock.__init__(self, SEMAPHORE, 1, 1, ctx=ctx)


 "/usr/local/intel-17/openmpi-2_0_1/python/3.5.1/lib/python3.5/multiprocessing/synchronize.py", line 81, in __init__

register(self._semlock.name)


 "/usr/local/intel-17/openmpi-2_0_1/python/3.5.1/lib/python3.5/multiprocessing/semaphore_tracker.py", line 69, in register

self._send('REGISTER', name)


 "/usr/local/intel-17/openmpi-2_0_1/python/3.5.1/lib/python3.5/multiprocessing/semaphore_tracker.py", line 82, in _send

nbytes = os.write(self._fd, msg)
BrokenPipeError: [Errno 32] Broken pipe
