def _bq_job_info()

in src/package/dataplexutils/metadata/wizard.py [0:0]

• 10 lines of code
• 2 McCabe index (conditional complexity)

    def _bq_job_info(self, bq_job_id, dataset_location):
        """Retrieves information about a BigQuery job.

        Args:
            bq_job_id (str): The ID of the BigQuery job
            dataset_location (str): The location of the dataset

        Returns:
            str: The query associated with the job

        Raises:
            Exception: If there is an error retrieving the job information
        """
        try:
            return (
                self._cloud_clients[constants["CLIENTS"]["BIGQUERY"]]
                .get_job(bq_job_id, location=dataset_location)
                .query
            )
        except Exception as e:
            logger.error(f"Exception: {e}.")
            raise e