From 93defa8be9a61a11def7f8737bb3932fc0e7bb3c Mon Sep 17 00:00:00 2001 From: Chris Hager Date: Sat, 1 Jun 2024 20:52:15 +0200 Subject: [PATCH] cleanup --- docs/adrs/202405-bidcollect.md | 6 +++--- services/bidcollect/data-api-poller.go | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/docs/adrs/202405-bidcollect.md b/docs/adrs/202405-bidcollect.md index abec029..07d4139 100644 --- a/docs/adrs/202405-bidcollect.md +++ b/docs/adrs/202405-bidcollect.md @@ -22,7 +22,7 @@ Run: go run . service bidcollect --out csv --data-api --ultrasound-stream ``` -#### Done +### Done - Ultrasound bid stream - Data API polling @@ -31,7 +31,7 @@ go run . service bidcollect --out csv --data-api --ultrasound-stream - Writing to csv for top and all bids - Cache for deduplication -#### Next up (must have) +### Next up (must have) - Diagram showing the flow of data and the components involved - File Output @@ -39,7 +39,7 @@ go run . service bidcollect --out csv --data-api --ultrasound-stream - Consider gzipped CSV output: https://gist.github.com/mchirico/6147687 (currently, an hour of bids is about 300MB) - Consider Parquet output files -#### Could have +### Could have **Data API polling** - consider improvements to timing diff --git a/services/bidcollect/data-api-poller.go b/services/bidcollect/data-api-poller.go index 8625d5e..375a509 100644 --- a/services/bidcollect/data-api-poller.go +++ b/services/bidcollect/data-api-poller.go @@ -88,7 +88,7 @@ func (poller *DataAPIPoller) pollRelaysForBids(slot uint64, t int64) { // Poll for bids now untilSlot := tSlotStart.Sub(time.Now().UTC()) - poller.Log.Debugf("[data-api poller] polling for slot %d at %d (tNow=%s)", slot, t, untilSlot.String()) + poller.Log.Debugf("[data-api poller] polling for slot %d at t=%d (tNow=%s)", slot, t, (untilSlot * -1).String()) for _, relay := range poller.Relays { go poller._pollRelayForBids(slot, relay, t)