Commit cf72f5be by Bach Dániel

update requirements

parent 988d0147
......@@ -3,7 +3,8 @@ from twisted.internet import reactor, inotify
from twisted.python import filepath
from agentcelery import celery, HOSTNAME
from protocol import inotify_handler
from os import getenv, listdir, path, environ
from os import getenv, listdir, path, environ, kill, getpid
import signal
import logging
logging.basicConfig()
......@@ -33,7 +34,8 @@ def reactor_started():
def reactor_stopped(worker):
worker.worker.stop()
logger.info("Reactor stopped.")
kill(getpid(), signal.SIGKILL)
def main():
......@@ -41,7 +43,7 @@ def main():
pool_cls='threads',
hostname=HOSTNAME + '.agentdriver',
loglevel=level)
reactor.callInThread(w.run)
reactor.callInThread(w.start)
notifier = inotify.INotify(reactor)
notifier.startReading()
notifier.watch(filepath.FilePath(SOCKET_DIR),
......
celery==3.0.24
celery==3.1.17
Twisted==13.1.0
threadpool==1.2.7
pylibmc==1.3.0
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment