handle longer than 600s pubsub timeout, may be dynamic ack ttl from sub or confi...

[github-actions]

event-sync/pkg/bq_load.go

Line 104 in 74dbd4c

// TODO handle longer than 600s pubsub timeout, may be dynamic ack ttl from sub or config?

				log.Fatal().Err(err).Msg("unable to close blob writer")
			}

			// TODO store blobs to persistant storage (local disk file, sql db, mongo, redis)
			blobs = append(blobs, blobName)
			// TODO store to go gob
			// labels: kill-handle
			log.Info().Int("messages", items).Msg("messages written to blob")
			// TODO handle longer than 600s pubsub timeout, may be dynamic ack ttl from sub or config?
			for _, ms := range messagesForAck {
				ms.Ack()
			}