Skip to content

Commit fa34ee4

Browse files
committed
Ensures execution of StartTask
1 parent b45a36f commit fa34ee4

3 files changed

Lines changed: 3 additions & 3 deletions

File tree

internal/test/workflow_integration_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -601,7 +601,7 @@ func TestResumeWorkflow(t *testing.T) {
601601
request := workflow.NewRequest(shortuuid.New(), wflow, params)
602602

603603
progress := workflow.InitProgress(workflow.ReqId(request.Id), wflow)
604-
pd := workflow.NewPartialData(workflow.ReqId(request.Id), wflow.Start.Next, "", request.Params)
604+
pd := workflow.NewPartialData(workflow.ReqId(request.Id), wflow.Start.Id, "", request.Params)
605605

606606
err = workflow.SaveProgress(progress, true)
607607
u.AssertNil(t, err)

internal/workflow/progress.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -207,7 +207,7 @@ func InitProgress(reqId ReqId, workflow *Workflow) *Progress {
207207
ReadyToExecute: make([]TaskId, 0),
208208
}
209209

210-
p.ReadyToExecute = append(p.ReadyToExecute, workflow.Start.Next)
210+
p.ReadyToExecute = append(p.ReadyToExecute, workflow.Start.Id)
211211

212212
return p
213213
}

internal/workflow/workflow.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -436,7 +436,7 @@ func (workflow *Workflow) Invoke(r *Request) (ExecutionReport, error) {
436436
// TODO: move into a function?
437437
if !r.Resuming {
438438
progress = InitProgress(requestId, workflow)
439-
pd = NewPartialData(requestId, workflow.Start.Next, "", r.Params)
439+
pd = NewPartialData(requestId, workflow.Start.Id, "", r.Params)
440440
} else {
441441
var found bool
442442
progress, found = RetrieveProgress(requestId, true)

0 commit comments

Comments
 (0)