Skip to content

Commit

Permalink
Fixing job id parameter, fixes #393 (#394)
Browse files Browse the repository at this point in the history
Change-Id: I04633599e3b76143b04028defa9668cbc2802ba1
  • Loading branch information
Jon Wayne Parrott authored Jun 30, 2016
1 parent 2fa20c0 commit 5d278e5
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
4 changes: 2 additions & 2 deletions bigquery/api/async_query.py
Original file line number Diff line number Diff line change
Expand Up @@ -33,12 +33,12 @@

# [START async_query]
def async_query(bigquery, project_id, query, batch=False, num_retries=5):
# Generate a unique job_id so retries
# Generate a unique job ID so retries
# don't accidentally duplicate query
job_data = {
'jobReference': {
'projectId': project_id,
'job_id': str(uuid.uuid4())
'jobId': str(uuid.uuid4())
},
'configuration': {
'query': {
Expand Down
2 changes: 1 addition & 1 deletion bigquery/api/export_data_to_cloud_storage.py
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ def export_table(bigquery, cloud_storage_path,
Returns: an extract job resource representing the
job, see https://cloud.google.com/bigquery/docs/reference/v2/jobs
"""
# Generate a unique job_id so retries
# Generate a unique job ID so retries
# don't accidentally duplicate export
job_data = {
'jobReference': {
Expand Down
4 changes: 2 additions & 2 deletions bigquery/api/load_data_from_csv.py
Original file line number Diff line number Diff line change
Expand Up @@ -50,12 +50,12 @@ def load_table(bigquery, project_id, dataset_id, table_name, source_schema,
https://cloud.google.com/bigquery/docs/reference/v2/jobs#configuration.load
"""

# Generate a unique job_id so retries
# Generate a unique job ID so retries
# don't accidentally duplicate query
job_data = {
'jobReference': {
'projectId': project_id,
'job_id': str(uuid.uuid4())
'jobId': str(uuid.uuid4())
},
'configuration': {
'load': {
Expand Down

0 comments on commit 5d278e5

Please sign in to comment.