| |
@@ -20,7 +20,7 @@
|
| |
log = logging.getLogger()
|
| |
|
| |
base_url = 'https://apps.fedoraproject.org/datagrepper/raw'
|
| |
- topic = "org.fedoraproject.prod.fedimg.image.upload"
|
| |
+ topic = "org.fedoraproject.prod.fedimg.image.publish"
|
| |
|
| |
|
| |
def get_page(page, pages, delta):
|
| |
@@ -34,8 +34,6 @@
|
| |
return response.json()
|
| |
|
| |
|
| |
- completed = lambda message: message['msg']['status'] == 'completed'
|
| |
-
|
| |
|
| |
def get_messages(days):
|
| |
""" Generator that yields messages from datagrepper """
|
| |
@@ -45,8 +43,7 @@
|
| |
# Get the first page
|
| |
data = get_page(1, 'unknown', delta)
|
| |
for message in data['raw_messages']:
|
| |
- if completed(message):
|
| |
- yield message
|
| |
+ yield message
|
| |
|
| |
more = functools.partial(get_page, pages=data['pages'], delta=delta)
|
| |
|
| |
@@ -55,8 +52,7 @@
|
| |
data = more(page + 1)
|
| |
|
| |
for message in data['raw_messages']:
|
| |
- if completed(message):
|
| |
- yield message
|
| |
+ yield message
|
| |
|
| |
|
| |
def parse_args():
|
| |
@@ -98,4 +94,4 @@
|
| |
extra.get('id', '').ljust(15),
|
| |
extra.get('virt_type', '').ljust(13),
|
| |
extra.get('vol_type', '').ljust(15),
|
| |
- )
|
| |
\ No newline at end of file
|
| |
+ )
|
| |
With fedimg 2.0.0, org.fedoraproject.prod.fedimg.image.publish
fedmsg topic is used to notify that AMIs are successfully
published to AWS EC2 regions. Fedmsg topic
org.fedoraproject.prod.fedimg.image.upload is sent only when
image gets successfully uploaded to base region.
Signed-off-by: Sinny Kumari sinny@redhat.com