diff --git a/airflow/providers/common/sql/operators/sql.py b/airflow/providers/common/sql/operators/sql.py index cf42fa4f57363..979f815c5bbc0 100644 --- a/airflow/providers/common/sql/operators/sql.py +++ b/airflow/providers/common/sql/operators/sql.py @@ -837,14 +837,13 @@ def execute(self, context: Context): pass_value_conv = _convert_to_float_if_possible(self.pass_value) is_numeric_value_check = isinstance(pass_value_conv, float) - tolerance_pct_str = str(self.tol * 100) + "%" if self.tol is not None else None error_msg = ( "Test failed.\nPass value:{pass_value_conv}\n" "Tolerance:{tolerance_pct_str}\n" "Query:\n{sql}\nResults:\n{records!s}" ).format( pass_value_conv=pass_value_conv, - tolerance_pct_str=tolerance_pct_str, + tolerance_pct_str=f"{self.tol:.1%}" if self.tol is not None else None, sql=self.sql, records=records, ) diff --git a/airflow/providers/google/cloud/hooks/bigquery.py b/airflow/providers/google/cloud/hooks/bigquery.py index 96340c0d50002..9f4be0d4f8f87 100644 --- a/airflow/providers/google/cloud/hooks/bigquery.py +++ b/airflow/providers/google/cloud/hooks/bigquery.py @@ -3182,7 +3182,6 @@ def value_check( raise AirflowException("The query returned None") pass_value_conv = self._convert_to_float_if_possible(pass_value) is_numeric_value_check = isinstance(pass_value_conv, float) - tolerance_pct_str = str(tolerance * 100) + "%" if tolerance else None error_msg = ( "Test failed.\nPass value:{pass_value_conv}\n" @@ -3190,7 +3189,7 @@ def value_check( "Query:\n{sql}\nResults:\n{records!s}" ).format( pass_value_conv=pass_value_conv, - tolerance_pct_str=tolerance_pct_str, + tolerance_pct_str=f"{tolerance:.1%}" if tolerance else None, sql=sql, records=records, ) diff --git a/dev/breeze/src/airflow_breeze/utils/parallel.py b/dev/breeze/src/airflow_breeze/utils/parallel.py index 70f5ec737eecb..9e2ffb64950d4 100644 --- a/dev/breeze/src/airflow_breeze/utils/parallel.py +++ b/dev/breeze/src/airflow_breeze/utils/parallel.py @@ -402,7 +402,7 @@ def check_async_run_results( completed_number = current_completed_number get_console().print( f"\n[info]Completed {completed_number} out of {total_number_of_results} " - f"({int(100*completed_number/total_number_of_results)}%).[/]\n" + f"({completed_number / total_number_of_results:.0%}).[/]\n" ) print_async_summary(completed_list) time.sleep(poll_time_seconds) @@ -410,7 +410,7 @@ def check_async_run_results( completed_number = len(completed_list) get_console().print( f"\n[info]Completed {completed_number} out of {total_number_of_results} " - f"({int(100*completed_number/total_number_of_results)}%).[/]\n" + f"({completed_number / total_number_of_results:.0%}).[/]\n" ) print_async_summary(completed_list) errors = False diff --git a/dev/system_tests/update_issue_status.py b/dev/system_tests/update_issue_status.py index 34a0262170273..83ba3a73e8621 100755 --- a/dev/system_tests/update_issue_status.py +++ b/dev/system_tests/update_issue_status.py @@ -171,7 +171,7 @@ def update_issue_status( console.print(f"[blue]Summary of performed actions: for {issue.title}[/]") console.print(f" Re-added file number (still there): {count_re_added}") console.print(f" Completed file number: {count_completed}") - console.print(f" Done {count_done}/{count_all} = {(count_done * 100/ count_all):.2f}%") + console.print(f" Done {count_done}/{count_all} = {count_done / count_all:.2%}") console.print() total_re_added += count_re_added total_completed += count_completed @@ -199,11 +199,11 @@ def update_issue_status( console.print(f"[green]Summary of ALL issues: for {num_issues} issues[/]") console.print( f" Completed and closed issues: {len(completed_closed_issues)}/{num_issues}: " - f"{len(completed_closed_issues) * 100/num_issues:.2f}%" + f"{len(completed_closed_issues) / num_issues:.2%}" ) console.print( f" Completed files {total_count_done}/{total_count_all} = " - f"{(total_count_done * 100/ total_count_all):.2f}%" + f"{total_count_done / total_count_all:.2%}" ) console.print() if not_completed_closed_issues: @@ -211,10 +211,7 @@ def update_issue_status( for issue in not_completed_closed_issues: all = per_issue_num_all[issue.id] done = per_issue_num_done[issue.id] - console.print( - rf" * [[yellow]{issue.title}[/]]({issue.html_url}): " - f"{done}/{all} : {done * 100 / all:.2f}%" - ) + console.print(f" * [[yellow]{issue.title}[/]]({issue.html_url}): {done}/{all} : {done / all:.2%}") console.print() if completed_open_issues: console.print("[yellow] Issues that are completed and should be closed:[/]\n") @@ -226,10 +223,7 @@ def update_issue_status( for issue in not_completed_opened_issues: all = per_issue_num_all[issue.id] done = per_issue_num_done[issue.id] - console.print( - rf" * [[yellow]{issue.title}[/]]({issue.html_url}): " - f"{done}/{all} : {done * 100 / all:.2f}%" - ) + console.print(f" * [[yellow]{issue.title}[/]]({issue.html_url}): {done}/{all} : {done / all:.2%}") console.print() if completed_closed_issues: console.print("[green] Issues that are completed and are already closed:[/]\n")