fedimg: Fix the trigger_upload script a/c to fedimg==1.1.0
Signed-off-by: Sayan Chowdhury <sayan.chowdhury2012@gmail.com>
This commit is contained in:
parent
ecf57d16a7
commit
a113d67b62
1 changed files with 29 additions and 18 deletions
|
@ -2,34 +2,45 @@
|
||||||
# -*- coding: utf8 -*-
|
# -*- coding: utf8 -*-
|
||||||
""" Triggers an upload process with the specified raw.xz URL. """
|
""" Triggers an upload process with the specified raw.xz URL. """
|
||||||
|
|
||||||
|
import argparse
|
||||||
import logging
|
import logging
|
||||||
import logging.config
|
import logging.config
|
||||||
import multiprocessing.pool
|
import multiprocessing.pool
|
||||||
import sys
|
|
||||||
|
|
||||||
import fedmsg
|
|
||||||
import fedmsg.config
|
import fedmsg.config
|
||||||
|
|
||||||
import fedimg
|
|
||||||
import fedimg.services
|
|
||||||
from fedimg.services.ec2 import EC2Service, EC2ServiceException
|
|
||||||
import fedimg.uploader
|
import fedimg.uploader
|
||||||
from fedimg.util import virt_types_from_url
|
|
||||||
|
|
||||||
if len(sys.argv) != 3:
|
|
||||||
print 'Usage: trigger_upload.py <rawxz_image_url> <compose_id>'
|
|
||||||
sys.exit(1)
|
|
||||||
|
|
||||||
logging.config.dictConfig(fedmsg.config.load_config()['logging'])
|
logging.config.dictConfig(fedmsg.config.load_config()['logging'])
|
||||||
log = logging.getLogger('fedmsg')
|
log = logging.getLogger('fedmsg')
|
||||||
|
|
||||||
|
|
||||||
|
def trigger_upload(compose_id, url, push_notifications):
|
||||||
upload_pool = multiprocessing.pool.ThreadPool(processes=4)
|
upload_pool = multiprocessing.pool.ThreadPool(processes=4)
|
||||||
|
compose_meta = {'compose_id': compose_id}
|
||||||
url = sys.argv[1]
|
|
||||||
compose_id = sys.argv[2]
|
|
||||||
|
|
||||||
compose_meta = {
|
|
||||||
'compose_id': compose_id
|
|
||||||
}
|
|
||||||
|
|
||||||
fedimg.uploader.upload(upload_pool, [url], compose_meta=compose_meta)
|
fedimg.uploader.upload(upload_pool, [url], compose_meta=compose_meta)
|
||||||
|
|
||||||
|
|
||||||
|
def get_args():
|
||||||
|
parser = argparse.ArgumentParser(
|
||||||
|
description="Trigger a manual upload process with the "
|
||||||
|
"specified raw.xz URL")
|
||||||
|
parser.add_argument(
|
||||||
|
"-u", "--url", type=str, help=".raw.xz URL", required=True)
|
||||||
|
parser.add_argument(
|
||||||
|
"-c", "--compose-id", type=str, help="compose id of the .raw.xz file",
|
||||||
|
required=True)
|
||||||
|
parser.add_argument(
|
||||||
|
"-p", "--push-notifications",
|
||||||
|
help="Bool to check if we need to push fedmsg notifications",
|
||||||
|
action="store_true", required=False)
|
||||||
|
args = parser.parse_args()
|
||||||
|
|
||||||
|
return args.url, args.compose_id, args.push_notifications
|
||||||
|
|
||||||
|
|
||||||
|
def main():
|
||||||
|
url, compose_id, push_notifications = get_args()
|
||||||
|
trigger_upload(url, compose_id, push_notifications)
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
main()
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue