Revert "Try jepsen only run"

This reverts commit faecb502b8.

.github/workflows/pull_request.yml

@@ -109,6 +109,49 @@ jobs:
         with:
           name: changed_images
           path: ${{ runner.temp }}/changed_images.json
+  BuilderBinRelease:
+    needs: [DockerHubPush]
+    runs-on: [self-hosted, builder]
+    steps:
+      - name: Set envs
+        run: |
+          cat >> "$GITHUB_ENV" << 'EOF'
+          TEMP_PATH=${{runner.temp}}/build_check
+          IMAGES_PATH=${{runner.temp}}/images_path
+          REPO_COPY=${{runner.temp}}/build_check/ClickHouse
+          CACHES_PATH=${{runner.temp}}/../ccaches
+          BUILD_NAME=binary_release
+          EOF
+      - name: Download changed images
+        uses: actions/download-artifact@v2
+        with:
+          name: changed_images
+          path: ${{ env.IMAGES_PATH }}
+      - name: Clear repository
+        run: |
+          sudo rm -fr "$GITHUB_WORKSPACE" && mkdir "$GITHUB_WORKSPACE"
+      - name: Check out repository code
+        uses: actions/checkout@v2
+      - name: Build
+        run: |
+          git -C "$GITHUB_WORKSPACE" submodule sync --recursive
+          git -C "$GITHUB_WORKSPACE" submodule update --depth=1 --recursive --init --jobs=10
+          sudo rm -fr "$TEMP_PATH"
+          mkdir -p "$TEMP_PATH"
+          cp -r "$GITHUB_WORKSPACE" "$TEMP_PATH"
+          cd "$REPO_COPY/tests/ci" && python3 build_check.py "$BUILD_NAME"
+      - name: Upload build URLs to artifacts
+        if: ${{ success() || failure() }}
+        uses: actions/upload-artifact@v2
+        with:
+          name: ${{ env.BUILD_URLS }}
+          path: ${{ env.TEMP_PATH }}/${{ env.BUILD_URLS }}.json
+      - name: Cleanup
+        if: always()
+        run: |
+          docker ps --quiet | xargs --no-run-if-empty docker kill ||:
+          docker ps --all --quiet | xargs --no-run-if-empty docker rm -f ||:
+          sudo rm -fr "$TEMP_PATH" "$CACHES_PATH"
 #############################################################################################
 ###################################### JEPSEN TESTS #########################################
 #############################################################################################
@@ -117,5 +160,5 @@ jobs:
     # When it's skipped, all dependent tasks will be skipped too.
     # DO NOT add it there
     if: contains(github.event.pull_request.labels.*.name, 'jepsen-test')
-    needs: []
+    needs: [BuilderBinRelease]
     uses: ./.github/workflows/jepsen.yml

tests/ci/keeper_jepsen_check.py

@@ -14,7 +14,7 @@ from stopwatch import Stopwatch
 from upload_result_helper import upload_results
 from s3_helper import S3Helper
 from get_robot_token import get_best_robot_token, get_parameter_from_ssm
-from pr_info import FakePRInfo
+from pr_info import PRInfo
 from compress_files import compress_fast
 from commit_status_helper import post_commit_status
 from clickhouse_helper import ClickHouseHelper, prepare_tests_results_for_clickhouse
@@ -22,6 +22,7 @@ from version_helper import get_version_from_repo
 from tee_popen import TeePopen
 from ssh import SSHKey
 from build_download_helper import get_build_name_for_check
+from rerun_helper import RerunHelper
 
 JEPSEN_GROUP_NAME = "jepsen_group"
 DESIRED_INSTANCE_COUNT = 3
@@ -145,12 +146,26 @@ if __name__ == "__main__":
 
     stopwatch = Stopwatch()
 
-    pr_info = FakePRInfo()
-    pr_info.number = 41845
-    pr_info.sha = "26a5e3588a5839c5a475a6c52c23c73bcee51bfc"
+    pr_info = PRInfo()
+
+    logging.info(
+        "Start at PR number %s, commit sha %s labels %s",
+        pr_info.number,
+        pr_info.sha,
+        pr_info.labels,
+    )
+
+    if pr_info.number != 0 and "jepsen-test" not in pr_info.labels:
+        logging.info("Not jepsen test label in labels list, skipping")
+        sys.exit(0)
 
     gh = Github(get_best_robot_token(), per_page=100)
 
+    rerun_helper = RerunHelper(gh, pr_info, CHECK_NAME)
+    if rerun_helper.is_already_finished_by_status():
+        logging.info("Check is already finished according to github status, exiting")
+        sys.exit(0)
+
     if not os.path.exists(TEMP_PATH):
         os.makedirs(TEMP_PATH)