def save_bigquery()

in api-connector/src/utils.py [0:0]

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

    def save_bigquery(dataset_and_table, data, project_id=config.PROJECT_ID):
        logger.debug(f"Attempting to write to table '{dataset_and_table}'")

        client = bigquery.Client()
        table = client.get_table(f"{project_id}.{dataset_and_table}")
        rows = [data]

        errors = client.insert_rows_json(table, rows)

        if errors:
            logger.error(f"Errors: {errors}")
            return False

        logger.debug("Success.")

        return True