| kparal |
| taskotron-trigger |
This consumer is no longer relevant with D1157 and it hasn't ever been used anywhere. Not to mention that it doesn't probably even work.
None
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| Path | Packages | |||
|---|---|---|---|---|
| M | README.rst (2 lines) | |||
| M | fedmsg.d/taskotron-trigger.py (1 line) | |||
| D | M | jobtriggers/compose_complete_msg.py (55 lines) | ||
| M | jobtriggers/jobrunner.py (9 lines) | |||
| M | setup.py (1 line) | |||
| D | M | testing/test_compose_trigger.py (89 lines) |
| Commit | Tree | Parents | Author | Summary | Date |
|---|---|---|---|---|---|
| 5082515391b8 | c4b6bc6dafbb | b04005a257b0 | Martin Krizek | Remove old compose consumer (Show More…) | Mar 14 2017, 2:08 PM |
| Show First 20 Lines • Show All 111 Lines • ▼ Show 20 Line(s) | |||||
| 112 | 112 | | |||
| 113 | If you use the default trigger rules, you should see similar messages to | 113 | If you use the default trigger rules, you should see similar messages to | ||
| 114 | confirm they have been enabled:: | 114 | confirm they have been enabled:: | ||
| 115 | 115 | | |||
| 116 | [ fedmsg INFO] enabled by config - jobtriggers.dist_git_commit_msg:DistGitCommitJobConsumer | 116 | [ fedmsg INFO] enabled by config - jobtriggers.dist_git_commit_msg:DistGitCommitJobConsumer | ||
| 117 | [ fedmsg INFO] No backlog handling. status: None, url: None | 117 | [ fedmsg INFO] No backlog handling. status: None, url: None | ||
| 118 | [ fedmsg INFO] enabled by config - jobtriggers.koji_build_msg:KojiBuildCompletedJobConsumer | 118 | [ fedmsg INFO] enabled by config - jobtriggers.koji_build_msg:KojiBuildCompletedJobConsumer | ||
| 119 | [ fedmsg INFO] No backlog handling. status: None, url: None | 119 | [ fedmsg INFO] No backlog handling. status: None, url: None | ||
| 120 | [ fedmsg INFO] enabled by config - jobtriggers.compose_complete_msg:ComposeCompletedJobConsumer | | |||
| 121 | [ fedmsg INFO] No backlog handling. status: None, url: None | | |||
| 122 | [ fedmsg INFO] enabled by config - jobtriggers.koji_tag_msg:KojiTagChangedJobConsumer | 120 | [ fedmsg INFO] enabled by config - jobtriggers.koji_tag_msg:KojiTagChangedJobConsumer | ||
| 123 | [ fedmsg INFO] No backlog handling. status: None, url: None | 121 | [ fedmsg INFO] No backlog handling. status: None, url: None | ||
| 124 | 122 | | |||
| 125 | After a short time of waiting you should see new events being detected, e.g.:: | 123 | After a short time of waiting you should see new events being detected, e.g.:: | ||
| 126 | 124 | | |||
| 127 | [ fedmsg INFO] triggering rpmlint for kig-16.12.2-1.fc26 on x86_64 | 125 | [ fedmsg INFO] triggering rpmlint for kig-16.12.2-1.fc26 on x86_64 | ||
| 128 | [ fedmsg INFO] StreamRunner received: | 126 | [ fedmsg INFO] StreamRunner received: | ||
| 129 | item: kig-16.12.2-1.fc26 | 127 | item: kig-16.12.2-1.fc26 | ||
| Show All 10 Lines | |||||
| 1 | config = { | 1 | config = { | ||
|---|---|---|---|---|---|
| 2 | 'taskotron.kojitagchangedjobconsumer.enabled': True, | 2 | 'taskotron.kojitagchangedjobconsumer.enabled': True, | ||
| 3 | 'taskotron.kojibuildcompletedjobconsumer.enabled': True, | 3 | 'taskotron.kojibuildcompletedjobconsumer.enabled': True, | ||
| 4 | 'taskotron.composecompletedjobconsumer.enabled': True, | | |||
| 5 | 'taskotron.distgitcommitjobconsumer.enabled': True, | 4 | 'taskotron.distgitcommitjobconsumer.enabled': True, | ||
| 6 | 'taskotron.paguregitreceivejobconsumer.enabled': True, | 5 | 'taskotron.paguregitreceivejobconsumer.enabled': True, | ||
| 7 | 'taskotron.cloudcomposecompletedconsumer.enabled': True, | 6 | 'taskotron.cloudcomposecompletedconsumer.enabled': True, | ||
| 8 | } | 7 | } | ||
| This file was completely deleted. Show File Contents |
| 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 .compose_complete_msg import ComposeCompletedJobTrigger | | |||
| 11 | from .pagure_git_received import PagureGitReceiveJobTrigger | 10 | from .pagure_git_received import PagureGitReceiveJobTrigger | ||
| 12 | 11 | | |||
| 13 | 12 | | |||
| 14 | # set up logging | 13 | # set up logging | ||
| 15 | logger = logging.getLogger('Jobrunner') | 14 | logger = logging.getLogger('Jobrunner') | ||
| 16 | sh = logging.StreamHandler() | 15 | sh = logging.StreamHandler() | ||
| 17 | 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', | ||
| 18 | datefmt='%Y-%m-%d %H:%M:%S') | 17 | datefmt='%Y-%m-%d %H:%M:%S') | ||
| 19 | sh.setFormatter(formatter) | 18 | sh.setFormatter(formatter) | ||
| 20 | logger.addHandler(sh) | 19 | logger.addHandler(sh) | ||
| 21 | 20 | | |||
| 22 | 21 | | |||
| 23 | def datagrepper_jobs(start, end, deployment_type=config.deployment_type): | 22 | def datagrepper_jobs(start, end, deployment_type=config.deployment_type): | ||
| 24 | topics = [{ | 23 | topics = [{ | ||
| 25 | 'start': start, | 24 | 'start': start, | ||
| 26 | 'end': end, | 25 | 'end': end, | ||
| 27 | 'category': 'buildsys', | 26 | 'category': 'buildsys', | ||
| 28 | 'topic': 'org.fedoraproject.%s.buildsys.build.state.change' % deployment_type, | 27 | 'topic': 'org.fedoraproject.%s.buildsys.build.state.change' % deployment_type, | ||
| 29 | 'page': 1, | 28 | 'page': 1, | ||
| 30 | }, { | 29 | }, { | ||
| 31 | 'start': start, | 30 | 'start': start, | ||
| 32 | 'end': end, | 31 | 'end': end, | ||
| 33 | 'category': 'compose', | | |||
| 34 | 'topic': 'org.fedoraproject.%s.compose.*' % deployment_type, | | |||
| 35 | 'page': 1, | | |||
| 36 | }, { | | |||
| 37 | 'start': start, | | |||
| 38 | 'end': end, | | |||
| 39 | 'category': 'git', | 32 | 'category': 'git', | ||
| 40 | 'topic': 'org.fedoraproject.%s.git.receive' % deployment_type, | 33 | 'topic': 'org.fedoraproject.%s.git.receive' % deployment_type, | ||
| 41 | 'page': 1, | 34 | 'page': 1, | ||
| 42 | }, { | 35 | }, { | ||
| 43 | 'start': start, | 36 | 'start': start, | ||
| 44 | 'end': end, | 37 | 'end': end, | ||
| 45 | 'category': 'git', | 38 | 'category': 'git', | ||
| 46 | 'topic': 'io.pagure.%s.pagure.git.receive' % deployment_type, | 39 | 'topic': 'io.pagure.%s.pagure.git.receive' % deployment_type, | ||
| Show All 10 Lines | 49 | if not pages: | |||
| 57 | break | 50 | break | ||
| 58 | 51 | | |||
| 59 | logger.info('Processing jobs from datagrepper for topic ' | 52 | logger.info('Processing jobs from datagrepper for topic ' | ||
| 60 | '%s: page %d of %d', params['topic'], page, pages) | 53 | '%s: page %d of %d', params['topic'], page, pages) | ||
| 61 | 54 | | |||
| 62 | for msg in r.json()['raw_messages']: | 55 | for msg in r.json()['raw_messages']: | ||
| 63 | if msg['topic'].endswith('build.state.change'): | 56 | if msg['topic'].endswith('build.state.change'): | ||
| 64 | trigger = KojiBuildCompletedJobTrigger(logger) | 57 | trigger = KojiBuildCompletedJobTrigger(logger) | ||
| 65 | elif 'compose' in msg['topic']: | | |||
| 66 | trigger = ComposeCompletedJobTrigger(logger) | | |||
| 67 | elif msg['topic'].endswith('git.receive'): | 58 | elif msg['topic'].endswith('git.receive'): | ||
| 68 | if msg['topic'].startswith('io.pagure'): | 59 | if msg['topic'].startswith('io.pagure'): | ||
| 69 | trigger = PagureGitReceiveJobTrigger(logger) | 60 | trigger = PagureGitReceiveJobTrigger(logger) | ||
| 70 | else: | 61 | else: | ||
| 71 | trigger = DistGitCommitJobTrigger(logger) | 62 | trigger = DistGitCommitJobTrigger(logger) | ||
| 72 | else: | 63 | else: | ||
| 73 | logger.warning('Got an unexpected topic %s', msg['topic']) | 64 | logger.warning('Got an unexpected topic %s', msg['topic']) | ||
| 74 | continue | 65 | continue | ||
| Show All 29 Lines | |||||
| Show All 9 Lines | 9 | def run(self): | |||
|---|---|---|---|---|---|
| 10 | import subprocess | 10 | import subprocess | ||
| 11 | errno = subprocess.call(['py.test', 'testing']) | 11 | errno = subprocess.call(['py.test', 'testing']) | ||
| 12 | raise SystemExit(errno) | 12 | raise SystemExit(errno) | ||
| 13 | 13 | | |||
| 14 | 14 | | |||
| 15 | moksha_consumer = ( | 15 | moksha_consumer = ( | ||
| 16 | 'kojibuildcompletedjobconsumer = jobtriggers.koji_build_msg:KojiBuildCompletedJobConsumer', | 16 | 'kojibuildcompletedjobconsumer = jobtriggers.koji_build_msg:KojiBuildCompletedJobConsumer', | ||
| 17 | 'kojitagchangedjobconsumer = jobtriggers.koji_tag_msg:KojiTagChangedJobConsumer', | 17 | 'kojitagchangedjobconsumer = jobtriggers.koji_tag_msg:KojiTagChangedJobConsumer', | ||
| 18 | 'composecompletedjobconsumer = jobtriggers.compose_complete_msg:ComposeCompletedJobConsumer', | | |||
| 19 | 'distgitcommitjobconsumer = jobtriggers.dist_git_commit_msg:DistGitCommitJobConsumer', | 18 | 'distgitcommitjobconsumer = jobtriggers.dist_git_commit_msg:DistGitCommitJobConsumer', | ||
| 20 | 'paguregitreceivejobconsumer = jobtriggers.pagure_git_received:PagureGitReceiveJobConsumer', | 19 | 'paguregitreceivejobconsumer = jobtriggers.pagure_git_received:PagureGitReceiveJobConsumer', | ||
| 21 | 'cloudcomposejobconsumer = jobtriggers.cloud_compose_complete_msg:CloudComposeCompletedConsumer', | 20 | 'cloudcomposejobconsumer = jobtriggers.cloud_compose_complete_msg:CloudComposeCompletedConsumer', | ||
| 22 | ) | 21 | ) | ||
| 23 | 22 | | |||
| 24 | setup( | 23 | setup( | ||
| 25 | name='jobtriggers', | 24 | name='jobtriggers', | ||
| 26 | version='0.4.7', | 25 | version='0.4.7', | ||
| Show All 15 Lines | |||||
| This file was completely deleted. Show File Contents |