Skip to content

Commit 5fec058

Browse files
committed
support more event types
1 parent 253de65 commit 5fec058

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

bigframes/session/_io/bigquery/__init__.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -241,7 +241,13 @@ def add_and_trim_labels(job_config):
241241

242242

243243
def publish_bq_event(event):
244-
if isinstance(event, google.cloud.bigquery._job_helpers.QuerySentEvent):
244+
if isinstance(event, google.cloud.bigquery._job_helpers.QueryFinishedEvent):
245+
bf_event = bigframes.core.events.BigQueryFinishedEvent.from_bqclient(event)
246+
elif isinstance(event, google.cloud.bigquery._job_helpers.QueryReceivedEvent):
247+
bf_event = bigframes.core.events.BigQueryReceivedEvent.from_bqclient(event)
248+
elif isinstance(event, google.cloud.bigquery._job_helpers.QueryRetryEvent):
249+
bf_event = bigframes.core.events.BigQueryRetryEvent.from_bqclient(event)
250+
elif isinstance(event, google.cloud.bigquery._job_helpers.QuerySentEvent):
245251
bf_event = bigframes.core.events.BigQuerySentEvent.from_bqclient(event)
246252
else:
247253
bf_event = bigframes.core.events.BigQueryUnknownEvent(event)

0 commit comments

Comments
 (0)