|
29 | 29 | from airflow_breeze.utils.console import console_print |
30 | 30 | from airflow_breeze.utils.path_utils import AIRFLOW_ROOT_PATH |
31 | 31 | from airflow_breeze.utils.run_utils import run_command |
32 | | -from airflow_breeze.utils.shared_options import get_dry_run |
33 | 32 |
|
34 | 33 | # Pattern to match Airflow release versions (e.g., "3.0.5") |
35 | 34 | RELEASE_PATTERN = re.compile(r"^(?P<major>\d+)\.(?P<minor>\d+)\.(?P<patch>\d+)$") |
@@ -426,34 +425,26 @@ def airflow_release(version, task_sdk_version): |
426 | 425 | # Clone the asf repo |
427 | 426 | os.chdir("..") |
428 | 427 | working_dir = os.getcwd() |
| 428 | + clone_asf_repo(working_dir) |
429 | 429 | svn_dev_repo = f"{working_dir}/asf-dist/dev/airflow" |
430 | 430 | svn_release_repo = f"{working_dir}/asf-dist/release/airflow" |
| 431 | + console_print("SVN dev repo root:", svn_dev_repo) |
| 432 | + console_print("SVN release repo root:", svn_release_repo) |
431 | 433 |
|
432 | | - if get_dry_run(): |
433 | | - # Skip SVN clone in dry-run mode - use placeholder RCs for testing the workflow |
434 | | - console_print("[info]Skipping SVN operations in dry-run mode") |
435 | | - release_candidate = f"{version}rc1" |
436 | | - task_sdk_release_candidate = f"{task_sdk_version}rc1" if task_sdk_version else None |
437 | | - else: |
438 | | - clone_asf_repo(working_dir) |
439 | | - console_print("SVN dev repo root:", svn_dev_repo) |
440 | | - console_print("SVN release repo root:", svn_release_repo) |
441 | | - |
442 | | - console_print() |
443 | | - console_print("Finding latest release candidate from SVN dev directory...") |
444 | | - release_candidate = find_latest_release_candidate(version, svn_dev_repo, component="airflow") |
445 | | - if not release_candidate: |
446 | | - exit(f"No release candidate found for version {version} in SVN dev directory") |
447 | | - |
448 | | - task_sdk_release_candidate = None |
449 | | - if task_sdk_version: |
450 | | - task_sdk_release_candidate = find_latest_release_candidate( |
451 | | - task_sdk_version, svn_dev_repo, component="task-sdk" |
452 | | - ) |
453 | | - if not task_sdk_release_candidate: |
454 | | - exit( |
455 | | - f"No Task SDK release candidate found for version {task_sdk_version} in SVN dev directory" |
456 | | - ) |
| 434 | + # Find the latest release candidate for the given version |
| 435 | + console_print() |
| 436 | + console_print("Finding latest release candidate from SVN dev directory...") |
| 437 | + release_candidate = find_latest_release_candidate(version, svn_dev_repo, component="airflow") |
| 438 | + if not release_candidate: |
| 439 | + exit(f"No release candidate found for version {version} in SVN dev directory") |
| 440 | + |
| 441 | + task_sdk_release_candidate = None |
| 442 | + if task_sdk_version: |
| 443 | + task_sdk_release_candidate = find_latest_release_candidate( |
| 444 | + task_sdk_version, svn_dev_repo, component="task-sdk" |
| 445 | + ) |
| 446 | + if not task_sdk_release_candidate: |
| 447 | + exit(f"No Task SDK release candidate found for version {task_sdk_version} in SVN dev directory") |
457 | 448 |
|
458 | 449 | console_print() |
459 | 450 | console_print("Airflow Release candidate:", release_candidate) |
|
0 commit comments