Fix some flake8 complaints.

main
Vincent Driessen 11 years ago
parent f7e2375b36
commit d2bbd31c59

@ -19,7 +19,7 @@ def parse_args():
parser = argparse.ArgumentParser(description='Starts an RQ worker.') parser = argparse.ArgumentParser(description='Starts an RQ worker.')
add_standard_arguments(parser) add_standard_arguments(parser)
parser.add_argument('--burst', '-b', action='store_true', default=False, help='Run in burst mode (quit after all work is done)') parser.add_argument('--burst', '-b', action='store_true', default=False, help='Run in burst mode (quit after all work is done)') # noqa
parser.add_argument('--name', '-n', default=None, help='Specify a different name') parser.add_argument('--name', '-n', default=None, help='Specify a different name')
parser.add_argument('--worker-class', '-w', action='store', default='rq.Worker', help='RQ Worker class to use') parser.add_argument('--worker-class', '-w', action='store', default='rq.Worker', help='RQ Worker class to use')
parser.add_argument('--path', '-P', default='.', help='Specify the import path.') parser.add_argument('--path', '-P', default='.', help='Specify the import path.')
@ -27,7 +27,7 @@ def parse_args():
parser.add_argument('--worker-ttl', default=None, help='Default worker timeout to be used') parser.add_argument('--worker-ttl', default=None, help='Default worker timeout to be used')
parser.add_argument('--verbose', '-v', action='store_true', default=False, help='Show more output') parser.add_argument('--verbose', '-v', action='store_true', default=False, help='Show more output')
parser.add_argument('--quiet', '-q', action='store_true', default=False, help='Show less output') parser.add_argument('--quiet', '-q', action='store_true', default=False, help='Show less output')
parser.add_argument('--sentry-dsn', action='store', default=None, metavar='URL', help='Report exceptions to this Sentry DSN') parser.add_argument('--sentry-dsn', action='store', default=None, metavar='URL', help='Report exceptions to this Sentry DSN') # noqa
parser.add_argument('--pid', action='store', default=None, parser.add_argument('--pid', action='store', default=None,
help='Write the process ID number to a file at the specified path') help='Write the process ID number to a file at the specified path')
parser.add_argument('queues', nargs='*', help='The queues to listen on (default: \'default\')') parser.add_argument('queues', nargs='*', help='The queues to listen on (default: \'default\')')
@ -80,11 +80,10 @@ def main():
try: try:
queues = list(map(Queue, args.queues)) queues = list(map(Queue, args.queues))
w = worker_class( w = worker_class(queues,
queues, name=args.name,
name=args.name, default_worker_ttl=args.worker_ttl,
default_worker_ttl=args.worker_ttl, default_result_ttl=args.results_ttl)
default_result_ttl=args.results_ttl)
# Should we configure Sentry? # Should we configure Sentry?
if args.sentry_dsn: if args.sentry_dsn:

Loading…
Cancel
Save