Skip to content

Commit f53f72d

Browse files
authored
Add and emulate the issues found in the workflows involving coroutines into the replayersuite. (#1237)
* Added tests for parallel workflow * Added the test for coroutine where removal of branch should have caused failure * Added copyright info
1 parent ebb27dd commit f53f72d

File tree

3 files changed

+464
-0
lines changed

3 files changed

+464
-0
lines changed

test/replaytests/branch2.json

Lines changed: 304 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,304 @@
1+
[
2+
{
3+
"eventId": 1,
4+
"timestamp": 1679421395542158251,
5+
"eventType": "WorkflowExecutionStarted",
6+
"version": 0,
7+
"taskId": 5242880,
8+
"workflowExecutionStartedEventAttributes": {
9+
"workflowType": {
10+
"name": "branch2"
11+
},
12+
"taskList": {
13+
"name": "branchGroup"
14+
},
15+
"executionStartToCloseTimeoutSeconds": 60,
16+
"taskStartToCloseTimeoutSeconds": 60,
17+
"continuedExecutionRunId": "",
18+
"originalExecutionRunId": "89f3a29d-3fcc-454a-8a60-f1cbeac25d61",
19+
"identity": "75028@agautam-NV709R969P@@98934640-7270-40b8-bc6b-5e4f07dedddf",
20+
"firstExecutionRunId": "89f3a29d-3fcc-454a-8a60-f1cbeac25d61",
21+
"attempt": 0,
22+
"cronSchedule": "",
23+
"firstDecisionTaskBackoffSeconds": 0,
24+
"header": {}
25+
}
26+
},
27+
{
28+
"eventId": 2,
29+
"timestamp": 1679421395542229834,
30+
"eventType": "DecisionTaskScheduled",
31+
"version": 0,
32+
"taskId": 5242881,
33+
"decisionTaskScheduledEventAttributes": {
34+
"taskList": {
35+
"name": "branchGroup"
36+
},
37+
"startToCloseTimeoutSeconds": 60,
38+
"attempt": 0
39+
}
40+
},
41+
{
42+
"eventId": 3,
43+
"timestamp": 1679421395574811584,
44+
"eventType": "DecisionTaskStarted",
45+
"version": 0,
46+
"taskId": 5242886,
47+
"decisionTaskStartedEventAttributes": {
48+
"scheduledEventId": 2,
49+
"identity": "74835@agautam-NV709R969P@branchGroup@b7ad4c03-5743-457e-9b85-98ed94f25cf0",
50+
"requestId": "a5c44775-0b07-45f3-a071-2bcbe9d44ec3"
51+
}
52+
},
53+
{
54+
"eventId": 4,
55+
"timestamp": 1679421395596205084,
56+
"eventType": "DecisionTaskCompleted",
57+
"version": 0,
58+
"taskId": 5242889,
59+
"decisionTaskCompletedEventAttributes": {
60+
"scheduledEventId": 2,
61+
"startedEventId": 3,
62+
"identity": "74835@agautam-NV709R969P@branchGroup@b7ad4c03-5743-457e-9b85-98ed94f25cf0",
63+
"binaryChecksum": "bbf90d59747791397fd7d18d98635ee0"
64+
}
65+
},
66+
{
67+
"eventId": 5,
68+
"timestamp": 1679421395596437043,
69+
"eventType": "ActivityTaskScheduled",
70+
"version": 0,
71+
"taskId": 5242890,
72+
"activityTaskScheduledEventAttributes": {
73+
"activityId": "0",
74+
"activityType": {
75+
"name": "main.sampleActivity"
76+
},
77+
"taskList": {
78+
"name": "branchGroup"
79+
},
80+
"input": "ImJyYW5jaDEuMSIK",
81+
"scheduleToCloseTimeoutSeconds": 60,
82+
"scheduleToStartTimeoutSeconds": 60,
83+
"startToCloseTimeoutSeconds": 60,
84+
"heartbeatTimeoutSeconds": 20,
85+
"decisionTaskCompletedEventId": 4,
86+
"header": {}
87+
}
88+
},
89+
{
90+
"eventId": 6,
91+
"timestamp": 1679421395596661959,
92+
"eventType": "ActivityTaskScheduled",
93+
"version": 0,
94+
"taskId": 5242891,
95+
"activityTaskScheduledEventAttributes": {
96+
"activityId": "1",
97+
"activityType": {
98+
"name": "main.sampleActivity"
99+
},
100+
"taskList": {
101+
"name": "branchGroup"
102+
},
103+
"input": "ImJyYW5jaDIiCg==",
104+
"scheduleToCloseTimeoutSeconds": 60,
105+
"scheduleToStartTimeoutSeconds": 60,
106+
"startToCloseTimeoutSeconds": 60,
107+
"heartbeatTimeoutSeconds": 20,
108+
"decisionTaskCompletedEventId": 4,
109+
"header": {}
110+
}
111+
},
112+
{
113+
"eventId": 7,
114+
"timestamp": 1679421395596521584,
115+
"eventType": "ActivityTaskStarted",
116+
"version": 0,
117+
"taskId": 5242892,
118+
"activityTaskStartedEventAttributes": {
119+
"scheduledEventId": 5,
120+
"identity": "74835@agautam-NV709R969P@branchGroup@b7ad4c03-5743-457e-9b85-98ed94f25cf0",
121+
"requestId": "dcb61e2e-5f4e-450e-9a16-9514f6f77ce1",
122+
"attempt": 0,
123+
"lastFailureReason": ""
124+
}
125+
},
126+
{
127+
"eventId": 8,
128+
"timestamp": 1679421395596703084,
129+
"eventType": "ActivityTaskStarted",
130+
"version": 0,
131+
"taskId": 5242893,
132+
"activityTaskStartedEventAttributes": {
133+
"scheduledEventId": 6,
134+
"identity": "74835@agautam-NV709R969P@branchGroup@b7ad4c03-5743-457e-9b85-98ed94f25cf0",
135+
"requestId": "8ffc59e8-28ad-4cee-9236-b0a0c3018880",
136+
"attempt": 0,
137+
"lastFailureReason": ""
138+
}
139+
},
140+
{
141+
"eventId": 9,
142+
"timestamp": 1679421395611128001,
143+
"eventType": "ActivityTaskCompleted",
144+
"version": 0,
145+
"taskId": 5242896,
146+
"activityTaskCompletedEventAttributes": {
147+
"result": "IlJlc3VsdF9zYW1wbGVBY3Rpdml0eSIK",
148+
"scheduledEventId": 6,
149+
"startedEventId": 8,
150+
"identity": "74835@agautam-NV709R969P@branchGroup@b7ad4c03-5743-457e-9b85-98ed94f25cf0"
151+
}
152+
},
153+
{
154+
"eventId": 10,
155+
"timestamp": 1679421395611190251,
156+
"eventType": "DecisionTaskScheduled",
157+
"version": 0,
158+
"taskId": 5242898,
159+
"decisionTaskScheduledEventAttributes": {
160+
"taskList": {
161+
"name": "agautam-NV709R969P:a3dcf3ca-1933-4ea3-ab7b-48a8b7bb8c80"
162+
},
163+
"startToCloseTimeoutSeconds": 60,
164+
"attempt": 0
165+
}
166+
},
167+
{
168+
"eventId": 11,
169+
"timestamp": 1679421395619208626,
170+
"eventType": "ActivityTaskCompleted",
171+
"version": 0,
172+
"taskId": 5242902,
173+
"activityTaskCompletedEventAttributes": {
174+
"result": "IlJlc3VsdF9zYW1wbGVBY3Rpdml0eSIK",
175+
"scheduledEventId": 5,
176+
"startedEventId": 7,
177+
"identity": "74835@agautam-NV709R969P@branchGroup@b7ad4c03-5743-457e-9b85-98ed94f25cf0"
178+
}
179+
},
180+
{
181+
"eventId": 12,
182+
"timestamp": 1679421395630186168,
183+
"eventType": "DecisionTaskStarted",
184+
"version": 0,
185+
"taskId": 5242904,
186+
"decisionTaskStartedEventAttributes": {
187+
"scheduledEventId": 10,
188+
"identity": "74835@agautam-NV709R969P@branchGroup@b7ad4c03-5743-457e-9b85-98ed94f25cf0",
189+
"requestId": "c670b936-da05-49c2-818b-fcba2c76fdba"
190+
}
191+
},
192+
{
193+
"eventId": 13,
194+
"timestamp": 1679421395646137334,
195+
"eventType": "DecisionTaskCompleted",
196+
"version": 0,
197+
"taskId": 5242907,
198+
"decisionTaskCompletedEventAttributes": {
199+
"scheduledEventId": 10,
200+
"startedEventId": 12,
201+
"identity": "74835@agautam-NV709R969P@branchGroup@b7ad4c03-5743-457e-9b85-98ed94f25cf0",
202+
"binaryChecksum": "bbf90d59747791397fd7d18d98635ee0"
203+
}
204+
},
205+
{
206+
"eventId": 14,
207+
"timestamp": 1679421395646282959,
208+
"eventType": "ActivityTaskScheduled",
209+
"version": 0,
210+
"taskId": 5242908,
211+
"activityTaskScheduledEventAttributes": {
212+
"activityId": "2",
213+
"activityType": {
214+
"name": "main.sampleActivity"
215+
},
216+
"taskList": {
217+
"name": "branchGroup"
218+
},
219+
"input": "ImJyYW5jaDEuMiIK",
220+
"scheduleToCloseTimeoutSeconds": 60,
221+
"scheduleToStartTimeoutSeconds": 60,
222+
"startToCloseTimeoutSeconds": 60,
223+
"heartbeatTimeoutSeconds": 20,
224+
"decisionTaskCompletedEventId": 13,
225+
"header": {}
226+
}
227+
},
228+
{
229+
"eventId": 15,
230+
"timestamp": 1679421395646355501,
231+
"eventType": "ActivityTaskStarted",
232+
"version": 0,
233+
"taskId": 5242909,
234+
"activityTaskStartedEventAttributes": {
235+
"scheduledEventId": 14,
236+
"identity": "74835@agautam-NV709R969P@branchGroup@b7ad4c03-5743-457e-9b85-98ed94f25cf0",
237+
"requestId": "13dff1b3-3aab-43a1-ac05-225ea5be321b",
238+
"attempt": 0,
239+
"lastFailureReason": ""
240+
}
241+
},
242+
{
243+
"eventId": 16,
244+
"timestamp": 1679421395659456918,
245+
"eventType": "ActivityTaskCompleted",
246+
"version": 0,
247+
"taskId": 5242912,
248+
"activityTaskCompletedEventAttributes": {
249+
"result": "IlJlc3VsdF9zYW1wbGVBY3Rpdml0eSIK",
250+
"scheduledEventId": 14,
251+
"startedEventId": 15,
252+
"identity": "74835@agautam-NV709R969P@branchGroup@b7ad4c03-5743-457e-9b85-98ed94f25cf0"
253+
}
254+
},
255+
{
256+
"eventId": 17,
257+
"timestamp": 1679421395659505793,
258+
"eventType": "DecisionTaskScheduled",
259+
"version": 0,
260+
"taskId": 5242914,
261+
"decisionTaskScheduledEventAttributes": {
262+
"taskList": {
263+
"name": "agautam-NV709R969P:a3dcf3ca-1933-4ea3-ab7b-48a8b7bb8c80"
264+
},
265+
"startToCloseTimeoutSeconds": 60,
266+
"attempt": 0
267+
}
268+
},
269+
{
270+
"eventId": 18,
271+
"timestamp": 1679421395680873459,
272+
"eventType": "DecisionTaskStarted",
273+
"version": 0,
274+
"taskId": 5242918,
275+
"decisionTaskStartedEventAttributes": {
276+
"scheduledEventId": 17,
277+
"identity": "74835@agautam-NV709R969P@branchGroup@b7ad4c03-5743-457e-9b85-98ed94f25cf0",
278+
"requestId": "1072acaa-348c-4991-bee1-6ad7489460af"
279+
}
280+
},
281+
{
282+
"eventId": 19,
283+
"timestamp": 1679421395699105251,
284+
"eventType": "DecisionTaskCompleted",
285+
"version": 0,
286+
"taskId": 5242921,
287+
"decisionTaskCompletedEventAttributes": {
288+
"scheduledEventId": 17,
289+
"startedEventId": 18,
290+
"identity": "74835@agautam-NV709R969P@branchGroup@b7ad4c03-5743-457e-9b85-98ed94f25cf0",
291+
"binaryChecksum": "bbf90d59747791397fd7d18d98635ee0"
292+
}
293+
},
294+
{
295+
"eventId": 20,
296+
"timestamp": 1679421395699209709,
297+
"eventType": "WorkflowExecutionCompleted",
298+
"version": 0,
299+
"taskId": 5242922,
300+
"workflowExecutionCompletedEventAttributes": {
301+
"decisionTaskCompletedEventId": 19
302+
}
303+
}
304+
]

0 commit comments

Comments
 (0)