# Path: sio/sioworkersd/server.py
# class DuplicateWorker(Exception):
# class WorkerRejected(Exception):
# class WorkerServer(rpc.WorkerRPC):
# class WorkerServerFactory(ServerFactory):
#     def __init__(self):
#     def established(self, ignore=None):
#     def connectionLost(self, reason):
#     def __init__(self, manager):
#     def workerConnected(self, proto):
#     def workerDisconnected(self, proto):
# 
# Path: sio/protocol/rpc.py
# class TimeoutError(Exception):
#     pass


from sio.sioworkersd import server
from sio.protocol.rpc import TimeoutError
from twisted.application import service
from twisted.internet import reactor, defer
from twisted.logger import Logger
import six
from __future__ import absolute_import

log = Logger()

TASK_TIMEOUT = 60 * 60



# Path: sio/sioworkersd/server.py
# class DuplicateWorker(Exception):
# class WorkerRejected(Exception):
# class WorkerServer(rpc.WorkerRPC):
# class WorkerServerFactory(ServerFactory):
#     def __init__(self):
#     def established(self, ignore=None):
#     def connectionLost(self, reason):
#     def __init__(self, manager):
#     def workerConnected(self, proto):
#     def workerDisconnected(self, proto):
# 
# Path: sio/protocol/rpc.py
# class TimeoutError(Exception):
#     pass


# Path: sio/sioworkersd/workermanager.py
from sio.sioworkersd import server
from sio.protocol.rpc import TimeoutError
from twisted.application import service
from twisted.internet import reactor, defer
from twisted.logger import Logger
import six

from __future__ import absolute_import

log = Logger()

TASK_TIMEOUT = 60 * 60



class WorkerGone(Exception):