diff --git a/redash/query_runner/big_query.py b/redash/query_runner/big_query.py index 25f3193660..455b23d585 100644 --- a/redash/query_runner/big_query.py +++ b/redash/query_runner/big_query.py @@ -205,7 +205,7 @@ def _get_job_data(self, query): def _get_query_result(self, jobs, query): project_id = self._get_project_id() - job_data = self._get_job_data() + job_data = self._get_job_data(query) insert_response = jobs.insert(projectId=project_id, body=job_data).execute() current_row = 0 query_reply = _get_query_results(jobs, project_id=project_id, location=self._get_location(),