This is an automated email from the ASF dual-hosted git repository. rnhttr pushed a commit to branch RNHTTR-patch-1 in repository https://gitbox.apache.org/repos/asf/airflow.git
commit b01e96995eb61ae6a9ca11dba44b36a75ee47bf2 Author: Ryan Hatter <[email protected]> AuthorDate: Thu Jul 25 08:59:32 2024 -0400 Move noisy logs to debug --- airflow/providers/google/cloud/operators/bigquery.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/airflow/providers/google/cloud/operators/bigquery.py b/airflow/providers/google/cloud/operators/bigquery.py index d55651d06b..0f02fb2587 100644 --- a/airflow/providers/google/cloud/operators/bigquery.py +++ b/airflow/providers/google/cloud/operators/bigquery.py @@ -315,7 +315,7 @@ class BigQueryCheckOperator( # the next() call which the RowIterator does not resemble to. Hence, ignore the arg-type error. # Row passed to _validate_records is a collection of values only, without column names. self._validate_records(next(iter(job.result()), [])) # type: ignore[arg-type] - self.log.info("Current state of job %s is %s", job.job_id, job.state) + self.log.debug("Current state of job %s is %s", job.job_id, job.state) @staticmethod def _handle_job_error(job: BigQueryJob | UnknownJob) -> None: @@ -471,7 +471,7 @@ class BigQueryValueCheckOperator( # the next() call which the RowIterator does not resemble to. Hence, ignore the arg-type error. # Row passed to check_value is a collection of values only, without column names. self.check_value(next(iter(job.result()), [])) # type: ignore[arg-type] - self.log.info("Current state of job %s is %s", job.job_id, job.state) + self.log.debug("Current state of job %s is %s", job.job_id, job.state) @staticmethod def _handle_job_error(job: BigQueryJob | UnknownJob) -> None: @@ -3039,7 +3039,7 @@ class BigQueryInsertJobOperator(GoogleCloudBaseOperator, _BigQueryOpenLineageMix ), method_name="execute_complete", ) - self.log.info("Current state of job %s is %s", job.job_id, job.state) + self.log.debug("Current state of job %s is %s", job.job_id, job.state) self._handle_job_error(job) def execute_complete(self, context: Context, event: dict[str, Any]) -> str | None:
