You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by ad...@apache.org on 2023/01/17 06:33:13 UTC

[doris-thirdparty] 03/04: Refine the script trigger-cirrus-ci.py

This is an automated email from the ASF dual-hosted git repository.

adonisling pushed a commit to branch cirrus-test
in repository https://gitbox.apache.org/repos/asf/doris-thirdparty.git

commit 8663172521f29216c911d2c26e514458379ce9f5
Author: Adonis Ling <ad...@gmail.com>
AuthorDate: Fri Jan 13 00:00:55 2023 +0800

    Refine the script trigger-cirrus-ci.py
---
 .github/scripts/trigger-cirrus-ci.py | 17 ++++++++++++-----
 1 file changed, 12 insertions(+), 5 deletions(-)

diff --git a/.github/scripts/trigger-cirrus-ci.py b/.github/scripts/trigger-cirrus-ci.py
index bb7f8a3..a3bc194 100755
--- a/.github/scripts/trigger-cirrus-ci.py
+++ b/.github/scripts/trigger-cirrus-ci.py
@@ -109,7 +109,7 @@ class CirrusCI:
 
     def wait_build(self, build_id, timeout=None, interval=None):
         query = '''
-            query QueryBuild($build_id: ID!) {
+            subscription QueryBuild($build_id: ID!) {
                 build(id: $build_id) {
                     status
                 }
@@ -122,7 +122,13 @@ class CirrusCI:
 
         start_time = time.time()
         while (time.time() - start_time) / 60 < timeout:
-            response = self.request(query, variables)
+            try:
+                response = self.request(query, variables)
+            except Exception as e:
+                logger.warning(str(e))
+                time.sleep(interval * 2)
+                continue
+
             build = response['data']['build']
             if build is None:
                 raise RuntimeError(response)
@@ -168,9 +174,10 @@ def trigger(arguments):
     task_ids = ci.get_task_ids(build_id)
     logger.info('The task IDs of build {} is {}'.format(build_id, task_ids))
 
-    artifact_url = 'https://api.cirrus-ci.com/v1/artifact/task/{}/binary.zip'.format(task_ids[0])
-    logger.info('The url of the artifact is {}'.format(artifact_url))
-    print(artifact_url)
+    for task_id in task_ids:
+        artifact_url = 'https://api.cirrus-ci.com/v1/artifact/task/{}/binary.zip'.format(task_id)
+        logger.info('The url of the artifact is {}'.format(artifact_url))
+        print(artifact_url)
 
 
 logger = Logger().logger


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org