File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -315,13 +315,19 @@ def _sink_bigquery_setup(client):
315
315
client .update_dataset (dataset , ["access_entries" ]) # API call
316
316
# [END sink_dataset_permissions]
317
317
318
- return dataset
318
+ # create callback wrapper to delete dataset when done
319
+ class DatasetDeleter :
320
+ def delete (self ):
321
+ client .delete_dataset (dataset , delete_contents = True )
322
+
323
+ return dataset , DatasetDeleter ()
319
324
320
325
321
326
@snippet
322
327
def sink_bigquery (client , to_delete ):
323
328
"""Sink log entries to bigquery."""
324
- dataset = _sink_bigquery_setup (client )
329
+ dataset , dataset_deleter = _sink_bigquery_setup (client )
330
+ to_delete .append (dataset_deleter )
325
331
sink_name = "robots-bigquery-%d" % (_millis (),)
326
332
filter_str = "textPayload:robot"
327
333
You canβt perform that action at this time.
0 commit comments