From 583f4c2181a4a20bc240e977fa41315362e64931 Mon Sep 17 00:00:00 2001 From: Aditya Thebe Date: Mon, 2 Oct 2023 19:15:27 +0545 Subject: [PATCH] fix: query created_at & properties of event_queue (#3) * modify releaserc --- .releaserc | 4 ++-- event.go | 4 +++- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/.releaserc b/.releaserc index 347c034..a502bcf 100644 --- a/.releaserc +++ b/.releaserc @@ -8,8 +8,8 @@ plugins: - { type: chore, release: patch } - { type: refactor, release: patch } - { type: feat, release: patch } - - { type: ci, release: patch } - - { type: style, release: patch } + - { type: ci, release: false } + - { type: style, release: false } parserOpts: noteKeywords: - MAJOR RELEASE diff --git a/event.go b/event.go index 939b90f..d40ee34 100644 --- a/event.go +++ b/event.go @@ -30,6 +30,8 @@ func (t *Event) Scan(rows pgx.Row) error { err := rows.Scan( &t.ID, &t.Name, + &t.CreatedAt, + &t.Properties, &t.Error, &t.LastAttempt, &t.Attempts, @@ -98,7 +100,7 @@ func fetchEvents(ctx Context, tx pgx.Tx, watchEvents []string, batchSize int, op FOR UPDATE SKIP LOCKED LIMIT @batchSize ) - RETURNING id, name, error, last_attempt, attempts + RETURNING id, name, created_at, properties, error, last_attempt, attempts ` args := pgx.NamedArgs{