ahhh, glorious peace and quiet.
Run the consumer, note it doesn't spam your logs with useless
messages about new connections every five goddamn seconds.
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| Path | Packages | |||
|---|---|---|---|---|
| M | scheduler/fedora_openqa_schedule/cli.py (2 lines) | |||
| M | scheduler/fedora_openqa_schedule/consumer.py (2 lines) |
| Commit | Tree | Parents | Author | Summary | Date |
|---|---|---|---|---|---|
| e01b5ca0bc3f | 89ec84a42b53 | 6a76ab359c63 | Adam Williamson | make requests stop logging about new connections all the time (Show More…) | Mar 4 2016, 5:51 AM |
| Show First 20 Lines • Show All 88 Lines • ▼ Show 20 Line(s) | 85 | def run(): | |||
|---|---|---|---|---|---|
| 89 | args = parse_args() | 89 | args = parse_args() | ||
| 90 | loglevel = getattr( | 90 | loglevel = getattr( | ||
| 91 | logging, args.log_level.upper(), logging.INFO) | 91 | logging, args.log_level.upper(), logging.INFO) | ||
| 92 | if args.log_file: | 92 | if args.log_file: | ||
| 93 | logging.basicConfig(format="%(levelname)s:%(name)s:%(asctime)s:%(message)s", | 93 | logging.basicConfig(format="%(levelname)s:%(name)s:%(asctime)s:%(message)s", | ||
| 94 | filename=args.log_file, level=loglevel) | 94 | filename=args.log_file, level=loglevel) | ||
| 95 | else: | 95 | else: | ||
| 96 | logging.basicConfig(level=loglevel) | 96 | logging.basicConfig(level=loglevel) | ||
| 97 | # shut up, requests | ||||
| 98 | logging.getLogger('requests.packages.urllib3.connectionpool').setLevel(logging.WARNING) | ||||
| 97 | 99 | | |||
| 98 | wiki_url = "fedoraproject.org" | 100 | wiki_url = "fedoraproject.org" | ||
| 99 | if args.test: | 101 | if args.test: | ||
| 100 | logger.debug("using test wiki") | 102 | logger.debug("using test wiki") | ||
| 101 | wiki_url = "stg.fedoraproject.org" | 103 | wiki_url = "stg.fedoraproject.org" | ||
| 102 | 104 | | |||
| 103 | args.func(args, wiki_url) | 105 | args.func(args, wiki_url) | ||
| 104 | 106 | | |||
| ▲ Show 20 Lines • Show All 58 Lines • Show Last 20 Lines | |||||
| Show First 20 Lines • Show All 58 Lines • ▼ Show 20 Line(s) | 44 | if 'FINISHED' in status and location: | |||
|---|---|---|---|---|---|
| 59 | return 0 | 59 | return 0 | ||
| 60 | 60 | | |||
| 61 | return 1 | 61 | return 1 | ||
| 62 | 62 | | |||
| 63 | 63 | | |||
| 64 | def main(): | 64 | def main(): | ||
| 65 | """Main listener loop.""" | 65 | """Main listener loop.""" | ||
| 66 | logging.basicConfig(level=logging.INFO) | 66 | logging.basicConfig(level=logging.INFO) | ||
| 67 | # shut the hell up about new goddamn connections, requests | ||||
| 68 | logging.getLogger('requests.packages.urllib3.connectionpool').setLevel(logging.WARNING) | ||||
| 67 | try: | 69 | try: | ||
| 68 | # catch Pungi 4 'compose status change' messages and old-style | 70 | # catch Pungi 4 'compose status change' messages and old-style | ||
| 69 | # two-week Atomic compose 'staging.done' messages, which have | 71 | # two-week Atomic compose 'staging.done' messages, which have | ||
| 70 | # the release number in them, so we need a regex | 72 | # the release number in them, so we need a regex | ||
| 71 | topicpatt = re.compile( | 73 | topicpatt = re.compile( | ||
| 72 | r'^org\.fedoraproject\.prod\.(pungi\.compose\.status\.change|' | 74 | r'^org\.fedoraproject\.prod\.(pungi\.compose\.status\.change|' | ||
| 73 | 'compose\.\d+\.cloudimg-staging\.done)$') | 75 | 'compose\.\d+\.cloudimg-staging\.done)$') | ||
| 74 | for (name, endpoint, topic, msg) in fedmsg.tail_messages(): | 76 | for (name, endpoint, topic, msg) in fedmsg.tail_messages(): | ||
| Show All 10 Lines | |||||