Change the process of create-snapshot

Old process : create a repository -> make a latest link -> create an images
New process : create a repository -> create an images -> make a latest link

Change-Id: Idebe7eb0778ca4ebc185a6fa82d138763549d1be

diff --git a/job_create_snapshot.py b/job_create_snapshot.py
index 1a4c9a4..aad1efb 100755 (executable)
--- a/job_create_snapshot.py
+++ b/job_create_snapshot.py
@@ -333,7 +333,7 @@ def make_repo(project, backenddb, base_path, live_repo_base, base_id=None, ref_i
             'manifestdata': manifestdata,
         }
 
-def main():
+def main(action):
     """Script entry point."""
 
     print '---[JOB STARTED: %s ]-------------------------'
@@ -355,6 +355,15 @@ def main():
 
     project = content.get("project")
 
+    if action == "latest_link":
+        # update/create the latest repo link
+        print 'make_latest_link'
+        make_latest_link(os.path.join(content.get("base_path"), content.get("repo_path")))
+        # TRIGGER NEXT RSYNC-DOWNLOAD (MIRROR)
+        if os.getenv("RSYNC_DOWNLOAD_ENABLED", "0") != "0":
+            trigger_next('RSYNC_DOWNLOAD', content)
+        return
+
     build = BuildService(obs_api, obs_user, obs_passwd)
 
     unresolvable_broken_packages = {}
@@ -446,7 +455,11 @@ def main():
                           base_release_id, ref_project_id)
 
     # update/create the latest repo link
-    make_latest_link(os.path.join(base_path, repo_data['repo_path']))
+    #make_latest_link(os.path.join(base_path, repo_data['repo_path']))
+    trigger_next("LATEST_LINK", {"base_path" : base_path,
+                                 "repo_path" : repo_data['repo_path'],
+                                 "project": project,
+                                })
 
     # prepare trigger data for image creation jobs and snapdiff sync jobs
     trigger_data, trigger_snapdiff = prepare_trigger_data(
@@ -556,7 +569,11 @@ def main():
 
 if __name__ == '__main__':
     try:
-        sys.exit(main())
+        #set num
+        if len(sys.argv) > 1:
+           sys.exit(main(sys.argv[1]))
+        else:
+            sys.exit(main(sys.argv))
     except LocalError, error:
         print error
         sys.exit(1)