Skip to content

Commit b3eae4a

Browse files
committed
feat: add retries to sql macros
1 parent 5e33d41 commit b3eae4a

File tree

14 files changed

+1018
-1088
lines changed

14 files changed

+1018
-1088
lines changed

packages/common/chirp-workflow/core/src/db/crdb_nats/debug.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -157,7 +157,7 @@ impl DatabaseDebug for DatabaseCrdbNats {
157157
SET silence_ts = $2
158158
WHERE workflow_id = ANY($1)
159159
",
160-
workflow_ids,
160+
&workflow_ids,
161161
rivet_util::timestamp::now(),
162162
)
163163
.await?;
@@ -174,7 +174,7 @@ impl DatabaseDebug for DatabaseCrdbNats {
174174
SET wake_immediate = TRUE
175175
WHERE workflow_id = ANY($1)
176176
",
177-
workflow_ids,
177+
&workflow_ids,
178178
)
179179
.await?;
180180

@@ -599,7 +599,7 @@ impl DatabaseDebug for DatabaseCrdbNats {
599599
)
600600
SELECT 1
601601
",
602-
signal_ids,
602+
&signal_ids,
603603
rivet_util::timestamp::now(),
604604
)
605605
.await?;

0 commit comments

Comments
 (0)