Skip to content

Commit 9931bfe

Browse files
committed
more info, better
1 parent f6195e1 commit 9931bfe

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

main.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -208,9 +208,13 @@ def load_processed_files_into_bigquery(event, context):
208208
):
209209
publisher = pubsub_v1.PublisherClient()
210210
topic_path = publisher.topic_path(DEFAULT_PROJECT, PUBSUB_TOPIC)
211-
publisher.publish(
211+
print(
212+
"Publishing to {topic_path}: partition={partition},continue_publishing={str(continue_publishing)}"
213+
)
214+
future = publisher.publish(
212215
topic_path,
213216
b"",
214217
partition=partition,
215218
continue_publishing=str(continue_publishing),
216219
)
220+
print(future.result())

0 commit comments

Comments
 (0)