File tree Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Original file line number Diff line number Diff line change @@ -154,7 +154,6 @@ def load_processed_files_into_bigquery(event, context):
154
154
job_id_prefix = "linehaul_file_downloads" ,
155
155
location = "US" ,
156
156
job_config = job_config ,
157
- rewind = True ,
158
157
)
159
158
load_job .result ()
160
159
print (f"Loaded { load_job .output_rows } rows into { DATASET } :{ DOWNLOAD_TABLE } " )
@@ -163,10 +162,9 @@ def load_processed_files_into_bigquery(event, context):
163
162
load_job = bigquery_client .load_table_from_uri (
164
163
simple_source_uris ,
165
164
dataset_ref .table (SIMPLE_TABLE ),
166
- job_id_prefix = "linehaul_file_downloads " ,
165
+ job_id_prefix = "linehaul_simple_requests " ,
167
166
location = "US" ,
168
167
job_config = job_config ,
169
- rewind = True ,
170
168
)
171
169
load_job .result ()
172
170
print (f"Loaded { load_job .output_rows } rows into { DATASET } :{ SIMPLE_TABLE } " )
You can’t perform that action at this time.
0 commit comments