Skip to content

Commit ee044bf

Browse files
authored
Merge pull request #159 from cschleiden/cschleiden/test-workflow-before-activities
Handle workflow events before activities
2 parents b97d19b + 0c11274 commit ee044bf

File tree

1 file changed

+12
-10
lines changed

1 file changed

+12
-10
lines changed

tester/tester.go

Lines changed: 12 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -299,16 +299,7 @@ func (wt *workflowTester[TResult]) Execute(args ...interface{}) {
299299
}
300300
}
301301

302-
// Schedule activities
303-
for _, event := range result.ActivityEvents {
304-
gotNewEvents = true
305-
306-
a := event.Attributes.(*history.ActivityScheduledAttributes)
307-
wt.logger.Debug("Activity event", "activity", a.Name)
308-
309-
wt.scheduleActivity(tw.instance, event)
310-
}
311-
302+
// Schedule sub-workflows and handle x-workflow events
312303
for _, workflowEvent := range result.WorkflowEvents {
313304
gotNewEvents = true
314305
wt.logger.Debug("Workflow event", "event_type", workflowEvent.HistoryEvent.Type)
@@ -322,6 +313,17 @@ func (wt *workflowTester[TResult]) Execute(args ...interface{}) {
322313
}
323314
}
324315

316+
// Schedule activities
317+
for _, event := range result.ActivityEvents {
318+
gotNewEvents = true
319+
320+
a := event.Attributes.(*history.ActivityScheduledAttributes)
321+
wt.logger.Debug("Activity event", "activity", a.Name)
322+
323+
wt.scheduleActivity(tw.instance, event)
324+
}
325+
326+
// Schedule timers
325327
for _, timerEvent := range result.TimerEvents {
326328
gotNewEvents = true
327329
wt.logger.Debug("Timer event", "event_type", timerEvent.Type)

0 commit comments

Comments
 (0)