Commit d736adb4 authored by Magnus Runesson's avatar Magnus Runesson Committed by Tao Feng

Use config parameter for project_id (#178)

Use configuration parameter for Google Cloud project_id instead of hardcoded.
parent eae4b1e7
......@@ -103,7 +103,7 @@ class BigQueryWatermarkExtractor(BaseBigQueryExtractor):
table=tableRef['tableId']),
'useLegacySql': True
}
result = self.bigquery_service.jobs().query(projectId='rea-gcp-dataservices-dev', body=body).execute()
result = self.bigquery_service.jobs().query(projectId=self.project_id, body=body).execute()
if 'rows' not in result:
return
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment