Skip to content

Commit c34ee72

Browse files
committed
nit
1 parent 84c216d commit c34ee72

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

dbos/system_database.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -798,6 +798,11 @@ func (s *sysDB) cancelAllBefore(ctx context.Context, cutoffTime time.Time) error
798798
return nil
799799
}
800800

801+
type garbageCollectWorkflowsInput struct {
802+
cutoffEpochTimestampMs *int64
803+
rowsThreshold *int
804+
}
805+
801806
func (s *sysDB) garbageCollectWorkflows(ctx context.Context, input garbageCollectWorkflowsInput) error {
802807
// Validate input parameters
803808
if input.rowsThreshold != nil && *input.rowsThreshold <= 0 {
@@ -1971,11 +1976,6 @@ type dequeueWorkflowsInput struct {
19711976
applicationVersion string
19721977
}
19731978

1974-
type garbageCollectWorkflowsInput struct {
1975-
cutoffEpochTimestampMs *int64
1976-
rowsThreshold *int
1977-
}
1978-
19791979
func (s *sysDB) dequeueWorkflows(ctx context.Context, input dequeueWorkflowsInput) ([]dequeuedWorkflow, error) {
19801980
// Begin transaction with snapshot isolation
19811981
tx, err := s.pool.Begin(ctx)

0 commit comments

Comments
 (0)