File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change @@ -192,10 +192,16 @@ def load_processed_files_into_bigquery(event, context):
192
192
with storage_client .batch ():
193
193
for blob in download_source_blobs :
194
194
blob .delete ()
195
+ print (
196
+ f"Deleted { len (download_source_blobs )} blobs from gs://{ RESULT_BUCKET } /{ download_prefix } "
197
+ )
195
198
if len (simple_source_blobs ) > 0 :
196
199
with storage_client .batch ():
197
200
for blob in simple_source_blobs :
198
201
blob .delete ()
202
+ print (
203
+ f"Deleted { len (simple_source_blobs )} blobs from gs://{ RESULT_BUCKET } /{ simple_prefix } "
204
+ )
199
205
200
206
if continue_publishing and (
201
207
len (download_source_blobs ) > 0 or len (simple_source_blobs ) > 0
@@ -204,7 +210,7 @@ def load_processed_files_into_bigquery(event, context):
204
210
topic_path = publisher .topic_path (DEFAULT_PROJECT , PUBSUB_TOPIC )
205
211
publisher .publish (
206
212
topic_path ,
207
- b'' ,
213
+ b"" ,
208
214
partition = partition ,
209
215
continue_publishing = str (continue_publishing ),
210
216
)
You can’t perform that action at this time.
0 commit comments