Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit32c4827

Browse files
committed
fix: correct current_try increment during step retries
Fix bug where current_try was not properly incremented during step retriesdue to incorrect default value in increment_retries function.The issue was in Map.update/4 usage:- Map.update(retries, step_ref, 0, &(&1 + 1)) set retry count to 0 for first retry- Should be Map.update(retries, step_ref, 1, &(&1 + 1)) to set retry count to 1Also updated retry limit check from >= to > for correct max_retries semantics:- max_retries 1 should allow 1 retry (2 total attempts)- Previous check retry_count >= max_retries prevented thisChanges:- lib/reactor/executor/async.ex: Fix increment_retries default and limit check- lib/reactor/executor/sync.ex: Fix increment_retries default and limit check- test/reactor/executor/async_test.exs: Update test expectation- test/reactor/executor/compensation_test.exs: Add test case from@skandermFixes current_try progression: 0 → 1 → 2 instead of 0 → 0 → 1
1 parentd36a06d commit32c4827

File tree

4 files changed

+5
-11
lines changed

4 files changed

+5
-11
lines changed

‎lib/reactor/executor/async.ex‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -148,7 +148,7 @@ defmodule Reactor.Executor.Async do
148148
reactor
149149
|>drop_from_plan(task)
150150

151-
ifMap.get(state.retries,step.ref)>=step.max_retriesdo
151+
ifMap.get(state.retries,step.ref)>step.max_retriesdo
152152
error=
153153
error||
154154
RetriesExceededError.exception(
@@ -223,7 +223,7 @@ defmodule Reactor.Executor.Async do
223223
end
224224

225225
defpincrement_retries(state,step)do
226-
%{state|retries:Map.update(state.retries,step.ref,0,&(&1+1))}
226+
%{state|retries:Map.update(state.retries,step.ref,1,&(&1+1))}
227227
end
228228

229229
defpdrop_from_plan(reactor,step)do

‎lib/reactor/executor/sync.ex‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ defmodule Reactor.Executor.Sync do
3232
defphandle_completed_step(reactor,state,step,{:retry,error})do
3333
state=increment_retries(state,step)
3434

35-
ifMap.get(state.retries,step.ref)>=step.max_retriesdo
35+
ifMap.get(state.retries,step.ref)>step.max_retriesdo
3636
reactor=drop_from_plan(reactor,step)
3737

3838
error=
@@ -89,7 +89,7 @@ defmodule Reactor.Executor.Sync do
8989
end
9090

9191
defpincrement_retries(state,step)do
92-
%{state|retries:Map.update(state.retries,step.ref,0,&(&1+1))}
92+
%{state|retries:Map.update(state.retries,step.ref,1,&(&1+1))}
9393
end
9494

9595
defpdrop_from_plan(reactor,step)do

‎test/reactor/executor/async_test.exs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -211,7 +211,7 @@ defmodule Reactor.Executor.AsyncTest do
211211
refuteis_map_key(state.retries,doable.ref)
212212

213213
assert{_,_reactor,state}=handle_completed_steps(reactor,state)
214-
assertstate.retries[doable.ref]==0
214+
assertstate.retries[doable.ref]==1
215215
end
216216

217217
test"when one of the steps asks to retry (again), it increments the retry count for the step",

‎test/reactor/executor/compensation_test.exs‎

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -65,12 +65,6 @@ defmodule Reactor.Executor.CompensationTest do
6565
{:run_error,%RunStepError{error::fail},0},
6666
{:compensate_start,%RunStepError{error::fail},0},
6767
:compensate_retry,
68-
# Current behavior (current_try does not immediately increment).
69-
# Uncomment to make the test pass:
70-
# {:run_start, _, 0},
71-
# {:run_error, %RunStepError{error: :fail}, 0},
72-
# {:compensate_start, %RunStepError{error: :fail}, 0},
73-
# :compensate_retry,
7468
{:run_start,_,1},
7569
{:run_error,%RunStepError{error::fail},1},
7670
{:compensate_start,%RunStepError{error::fail},1},

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp