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):
315315 client .update_dataset (dataset , ["access_entries" ]) # API call
316316 # [END sink_dataset_permissions]
317317
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 ()
319324
320325
321326@snippet
322327def sink_bigquery (client , to_delete ):
323328 """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 )
325331 sink_name = "robots-bigquery-%d" % (_millis (),)
326332 filter_str = "textPayload:robot"
327333
You can’t perform that action at this time.
0 commit comments