mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-11-10 01:25:21 +00:00
Add argument to fill the gap in cherry-pick
This commit is contained in:
parent
325374c68b
commit
e11fa23032
@ -35,12 +35,7 @@ from typing import List, Optional
|
||||
from env_helper import TEMP_PATH
|
||||
from get_robot_token import get_best_robot_token
|
||||
from git_helper import git_runner, is_shallow
|
||||
from github_helper import (
|
||||
GitHub,
|
||||
PullRequest,
|
||||
PullRequests,
|
||||
Repository,
|
||||
)
|
||||
from github_helper import GitHub, PullRequest, PullRequests, Repository
|
||||
from ssh import SSHKey
|
||||
|
||||
|
||||
@ -423,7 +418,9 @@ class Backport:
|
||||
logging.info("Fetching from %s", self._fetch_from)
|
||||
fetch_from_repo = self.gh.get_repo(self._fetch_from)
|
||||
git_runner(
|
||||
f"git fetch {fetch_from_repo.ssh_url if self.is_remote_ssh else fetch_from_repo.clone_url} {fetch_from_repo.default_branch} --no-tags"
|
||||
"git fetch "
|
||||
f"{fetch_from_repo.ssh_url if self.is_remote_ssh else fetch_from_repo.clone_url} "
|
||||
f"{fetch_from_repo.default_branch} --no-tags"
|
||||
)
|
||||
|
||||
logging.info("Active releases: %s", ", ".join(self.release_branches))
|
||||
@ -443,7 +440,7 @@ class Backport:
|
||||
logging.info("Resetting %s to %s/%s", branch, self.remote, branch)
|
||||
git_runner(f"git branch -f {branch} {self.remote}/{branch}")
|
||||
|
||||
def receive_prs_for_backport(self):
|
||||
def receive_prs_for_backport(self, reserve_search_days: int) -> None:
|
||||
# The commits in the oldest open release branch
|
||||
oldest_branch_commits = git_runner(
|
||||
"git log --no-merges --format=%H --reverse "
|
||||
@ -453,7 +450,7 @@ class Backport:
|
||||
since_commit = oldest_branch_commits.split("\n", 1)[0]
|
||||
since_date = date.fromisoformat(
|
||||
git_runner.run(f"git log -1 --format=format:%cs {since_commit}")
|
||||
)
|
||||
) - timedelta(days=reserve_search_days)
|
||||
# To not have a possible TZ issues
|
||||
tomorrow = date.today() + timedelta(days=1)
|
||||
logging.info("Receive PRs suppose to be backported")
|
||||
@ -584,13 +581,18 @@ def parse_args():
|
||||
choices=(Labels.MUST_BACKPORT, Labels.MUST_BACKPORT_CLOUD),
|
||||
help="label to filter PRs to backport",
|
||||
)
|
||||
|
||||
parser.add_argument(
|
||||
"--backport-created-label",
|
||||
default=Labels.BACKPORTS_CREATED,
|
||||
choices=(Labels.BACKPORTS_CREATED, Labels.BACKPORTS_CREATED_CLOUD),
|
||||
help="label to mark PRs as backported",
|
||||
)
|
||||
parser.add_argument(
|
||||
"--reserve-search-days",
|
||||
default=0,
|
||||
type=int,
|
||||
help="safity reserve for the PRs search days, necessary for cloud",
|
||||
)
|
||||
|
||||
parser.add_argument(
|
||||
"--debug-helpers",
|
||||
@ -655,7 +657,7 @@ def main():
|
||||
bp.gh.cache_path = temp_path / "gh_cache"
|
||||
bp.receive_release_prs()
|
||||
bp.update_local_release_branches()
|
||||
bp.receive_prs_for_backport()
|
||||
bp.receive_prs_for_backport(args.reserve_search_days)
|
||||
bp.process_backports()
|
||||
if bp.error is not None:
|
||||
logging.error("Finished successfully, but errors occured!")
|
||||
|
Loading…
Reference in New Issue
Block a user