|
2 | 2 |
|
3 | 3 | from optparse import OptionParser |
4 | 4 |
|
5 | | -from itty import run_itty |
6 | | - |
7 | 5 | from pyres.horde import Khan |
8 | 6 | from pyres import setup_logging, setup_pidfile |
9 | 7 | from pyres.scheduler import Scheduler |
10 | | -from resweb import server as resweb_server |
11 | 8 | from pyres.worker import Worker |
12 | 9 |
|
13 | 10 |
|
@@ -60,42 +57,6 @@ def pyres_scheduler(): |
60 | 57 | Scheduler.run(server) |
61 | 58 |
|
62 | 59 |
|
63 | | -def pyres_web(): |
64 | | - usage = "usage: %prog [options]" |
65 | | - parser = OptionParser(usage) |
66 | | - parser.add_option("--host", |
67 | | - dest="host", |
68 | | - default="localhost", |
69 | | - metavar="HOST") |
70 | | - parser.add_option("--port", |
71 | | - dest="port", |
72 | | - type="int", |
73 | | - default=8080) |
74 | | - parser.add_option("--dsn", |
75 | | - dest="dsn", |
76 | | - help="Redis server to display") |
77 | | - parser.add_option("--auth", |
78 | | - dest="auth", |
79 | | - help="Redis user:pass") |
80 | | - parser.add_option("--server", |
81 | | - dest="server", |
82 | | - help="Server for itty to run under.", |
83 | | - default='wsgiref') |
84 | | - (options,args) = parser.parse_args() |
85 | | - |
86 | | - if options.dsn: |
87 | | - from pyres import ResQ |
88 | | - if options.auth is not None: |
89 | | - from redis import Redis |
90 | | - rhost, rport = options.dsn.split(':') |
91 | | - ruser, rpass = options.auth.split(':') |
92 | | - redis = Redis(host=rhost, port=int(rport), db=ruser, password=rpass) |
93 | | - resweb_server.HOST = ResQ(redis) |
94 | | - else: |
95 | | - resweb_server.HOST = ResQ(options.dsn) |
96 | | - run_itty(host=options.host, port=options.port, server=options.server) |
97 | | - |
98 | | - |
99 | 60 | def pyres_worker(): |
100 | 61 | usage = "usage: %prog [options] arg1" |
101 | 62 | parser = OptionParser(usage=usage) |
|
0 commit comments