Skip to content

Commit 5737914

Browse files
committed
use 3s delay
1 parent 157761d commit 5737914

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

internal/service/streamprocessor/state_transition.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,8 @@ func WaitStateTransition(ctx context.Context, requestParams *admin.GetStreamProc
3232
Target: desiredStates,
3333
Refresh: refreshFunc(ctx, requestParams, client),
3434
Timeout: 5 * time.Minute, // big pipelines can take a while to stop due to checkpointing. We prefer the API to raise the error (~ 3min) than having to expose custom timeouts.
35-
MinTimeout: 10 * time.Second,
36-
Delay: 10 * time.Second,
35+
MinTimeout: 3 * time.Second,
36+
Delay: 3 * time.Second,
3737
}
3838

3939
streamProcessorResp, err := stateConf.WaitForStateContext(ctx)

0 commit comments

Comments
 (0)