| kparal |
| taskotron-trigger |
This has been forgotten in the review
Ran the cli, StreamTrigger printed the expected output.
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| Path | Packages | |||
|---|---|---|---|---|
| M | jobtriggers/jobrunner.py (10 lines) |
| Commit | Tree | Parents | Author | Summary | Date |
|---|---|---|---|---|---|
| 9ec029a4eab5 | fa39e2e27630 | b04005a257b0 | Martin Krizek | Add cloudcompose trigger to the CLI (Show More…) | Mar 14 2017, 2:26 PM |
| 1 | import argparse | 1 | import argparse | ||
|---|---|---|---|---|---|
| 2 | import logging | 2 | import logging | ||
| 3 | 3 | | |||
| 4 | import requests | 4 | import requests | ||
| 5 | from . import config | 5 | from . import config | ||
| 6 | from . import exceptions as exc | 6 | from . import exceptions as exc | ||
| 7 | 7 | | |||
| 8 | from .koji_build_msg import KojiBuildCompletedJobTrigger | 8 | from .koji_build_msg import KojiBuildCompletedJobTrigger | ||
| 9 | from .dist_git_commit_msg import DistGitCommitJobTrigger | 9 | from .dist_git_commit_msg import DistGitCommitJobTrigger | ||
| 10 | from .pagure_git_received import PagureGitReceiveJobTrigger | 10 | from .pagure_git_received import PagureGitReceiveJobTrigger | ||
| 11 | 11 | from .cloud_compose_complete_msg import CloudComposeJobTrigger | |||
| 12 | 12 | | |||
| 13 | # set up logging | 13 | # set up logging | ||
| 14 | logger = logging.getLogger('Jobrunner') | 14 | logger = logging.getLogger('Jobrunner') | ||
| 15 | sh = logging.StreamHandler() | 15 | sh = logging.StreamHandler() | ||
| 16 | formatter = logging.Formatter(fmt='%(asctime)s - %(name)s - %(levelname)s: %(message)s', | 16 | formatter = logging.Formatter(fmt='%(asctime)s - %(name)s - %(levelname)s: %(message)s', | ||
| 17 | datefmt='%Y-%m-%d %H:%M:%S') | 17 | datefmt='%Y-%m-%d %H:%M:%S') | ||
| 18 | sh.setFormatter(formatter) | 18 | sh.setFormatter(formatter) | ||
| 19 | logger.addHandler(sh) | 19 | logger.addHandler(sh) | ||
| Show All 13 Lines | 29 | }, { | |||
| 33 | 'topic': 'org.fedoraproject.%s.git.receive' % deployment_type, | 33 | 'topic': 'org.fedoraproject.%s.git.receive' % deployment_type, | ||
| 34 | 'page': 1, | 34 | 'page': 1, | ||
| 35 | }, { | 35 | }, { | ||
| 36 | 'start': start, | 36 | 'start': start, | ||
| 37 | 'end': end, | 37 | 'end': end, | ||
| 38 | 'category': 'git', | 38 | 'category': 'git', | ||
| 39 | 'topic': 'io.pagure.%s.pagure.git.receive' % deployment_type, | 39 | 'topic': 'io.pagure.%s.pagure.git.receive' % deployment_type, | ||
| 40 | 'page': 1, | 40 | 'page': 1, | ||
| 41 | }, { | ||||
| 42 | 'start': start, | ||||
| 43 | 'end': end, | ||||
| 44 | 'category': 'pungi', | ||||
| 45 | 'topic': 'org.fedoraproject.%s.pungi.compose.status.change' % deployment_type, | ||||
| 46 | 'page': 1, | ||||
| 41 | }] | 47 | }] | ||
| 42 | 48 | | |||
| 43 | for params in topics: | 49 | for params in topics: | ||
| 44 | while True: | 50 | while True: | ||
| 45 | r = requests.get(config.datagrepper_url, params=params) | 51 | r = requests.get(config.datagrepper_url, params=params) | ||
| 46 | pages = r.json()['pages'] | 52 | pages = r.json()['pages'] | ||
| 47 | page = r.json()['arguments']['page'] | 53 | page = r.json()['arguments']['page'] | ||
| 48 | 54 | | |||
| 49 | if not pages: | 55 | if not pages: | ||
| 50 | break | 56 | break | ||
| 51 | 57 | | |||
| 52 | logger.info('Processing jobs from datagrepper for topic ' | 58 | logger.info('Processing jobs from datagrepper for topic ' | ||
| 53 | '%s: page %d of %d', params['topic'], page, pages) | 59 | '%s: page %d of %d', params['topic'], page, pages) | ||
| 54 | 60 | | |||
| 55 | for msg in r.json()['raw_messages']: | 61 | for msg in r.json()['raw_messages']: | ||
| 56 | if msg['topic'].endswith('build.state.change'): | 62 | if msg['topic'].endswith('build.state.change'): | ||
| 57 | trigger = KojiBuildCompletedJobTrigger(logger) | 63 | trigger = KojiBuildCompletedJobTrigger(logger) | ||
| 64 | elif 'pungi' in msg['topic']: | ||||
| 65 | trigger = CloudComposeJobTrigger(logger) | ||||
| 58 | elif msg['topic'].endswith('git.receive'): | 66 | elif msg['topic'].endswith('git.receive'): | ||
| 59 | if msg['topic'].startswith('io.pagure'): | 67 | if msg['topic'].startswith('io.pagure'): | ||
| 60 | trigger = PagureGitReceiveJobTrigger(logger) | 68 | trigger = PagureGitReceiveJobTrigger(logger) | ||
| 61 | else: | 69 | else: | ||
| 62 | trigger = DistGitCommitJobTrigger(logger) | 70 | trigger = DistGitCommitJobTrigger(logger) | ||
| 63 | else: | 71 | else: | ||
| 64 | logger.warning('Got an unexpected topic %s', msg['topic']) | 72 | logger.warning('Got an unexpected topic %s', msg['topic']) | ||
| 65 | continue | 73 | continue | ||
| Show All 29 Lines | |||||