Add timeout to worker

Author: langdal

optimizerapi/worker.py

@@ -11,7 +11,12 @@
 else:
     REDIS_URL = "redis://localhost:6379"
 
+if "WORKER_TIMEOUT" in os.environ:
+    WORKER_TIMEOUT = int(os.environ["WORKER_TIMEOUT"])
+else:
+    WORKER_TIMEOUT = 180
+
 if __name__ == "__main__":
     redis = Redis.from_url(REDIS_URL)
-    queue = Queue(connection=redis)
+    queue = Queue(connection=redis, deafult_timeout=WORKER_TIMEOUT)
     Worker(queue).work()