8000 StepFunctions, Add support for Task Timeouts (#8376) · codeperl/localstack@0caa19d · GitHub
[go: up one dir, main page]
Skip to content

Commit 0caa19d

Browse files
MEPalmaMEPalma
authored
StepFunctions, Add support for Task Timeouts (localstack#8376)
1 parent a5e443b commit 0caa19d

File tree

85 files changed

+4145
-2374
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

85 files changed

+4145
-2374
lines changed

‎localstack/services/stepfunctions/asl/antlr/ASLLexer.g4

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -82,6 +82,9 @@ SECONDS: '"Seconds"';
8282
TIMESTAMPPATH: '"TimestampPath"';
8383
TIMESTAMP: '"Timestamp"';
8484

85+
TIMEOUTSECONDS: '"TimeoutSeconds"';
86+
TIMEOUTSECONDSPATH: '"TimeoutSecondsPath"';
87+
8588
PROCESSORCONFIG: '"ProcessorConfig"';
8689
MODE: '"Mode"';
8790
INLINE: '"INLINE"';

‎localstack/services/stepfunctions/asl/antlr/ASLParser.g4

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,8 @@ state_stmt
4545
| items_path_decl
4646
| item_processor_decl
4747
| max_concurrency_decl
48+
| timeout_seconds_decl
49+
| timeout_seconds_path_decl
4850
| branches_decl
4951
| parameters_decl
5052
| retry_decl
@@ -149,6 +151,15 @@ parameters_decl
149151
: PARAMETERS COLON payload_tmpl_decl
150152
;
151153

154+
timeout_seconds_decl
155+
: TIMEOUTSECONDS COLON INT
156+
;
157+
158+
timeout_seconds_path_decl
159+
: TIMEOUTSECONDSPATH COLON STRINGPATH
160+
;
161+
162+
152163
payload_tmpl_decl
153164
: LBRACE payload_binding (COMMA payload_binding)* RBRACE
154165
| LBRACE RBRACE

‎localstack/services/stepfunctions/asl/antlr/runtime/ASLLexer.interp

Lines changed: 7 additions & 1 deletion
Large diffs are not rendered by default.

‎localstack/services/stepfunctions/asl/antlr/runtime/ASLLexer.py

Lines changed: 791 additions & 771 deletions
Large diffs are not rendered by default.

‎localstack/services/stepfunctions/asl/antlr/runtime/ASLLexer.tokens

Lines changed: 85 additions & 81 deletions
Original file line numberDiff line numberDiff line change
@@ -70,50 +70,52 @@ SECONDSPATH=69
7070
SECONDS=70
7171
TIMESTAMPPATH=71
7272
TIMESTAMP=72
73-
PROCESSORCONFIG=73
74-
MODE=74
75-
INLINE=75
76-
ITEMPROCESSOR=76
77-
MAXCONCURRENCY=77
78-
RESOURCE=78
79-
INPUTPATH=79
80-
OUTPUTPATH=80
81-
ITEMSPATH=81
82-
RESULTPATH=82
83-
RESULT=83
84-
PARAMETERS=84
85-
RESULTSELECTOR=85
86-
NEXT=86
87-
END=87
88-
CAUSE=88
89-
ERROR=89< 7802 /div>
90-
RETRY=90
91-
ERROREQUALS=91
92-
INTERVALSECONDS=92
93-
MAXATTEMPTS=93
94-
BACKOFFRATE=94
95-
CATCH=95
96-
ERRORNAMEStatesALL=96
97-
ERRORNAMEStatesHeartbeatTimeout=97
98-
ERRORNAMEStatesTimeout=98
99-
ERRORNAMEStatesTaskFailed=99
100-
ERRORNAMEStatesPermissions=100
101-
ERRORNAMEStatesResultPathMatchFailure=101
102-
ERRORNAMEStatesParameterPathFailure=102
103-
ERRORNAMEStatesBranchFailed=103
104-
ERRORNAMEStatesNoChoiceMatched=104
105-
ERRORNAMEStatesIntrinsicFailure=105
106-
ERRORNAMEStatesExceedToleratedFailureThreshold=106
107-
ERRORNAMEStatesItemReaderFailed=107
108-
ERRORNAMEStatesResultWriterFailed=108
109-
ERRORNAMEStatesRuntime=109
110-
STRINGDOLLAR=110
111-
STRINGPATHCONTEXTOBJ=111
112-
STRINGPATH=112
113-
STRING=113
114-
INT=114
115-
NUMBER=115
116-
WS=116
73+
TIMEOUTSECONDS=73
74+
TIMEOUTSECONDSPATH=74
75+
PROCESSORCONFIG=75
76+
MODE=76
77+
INLINE=77
78+
ITEMPROCESSOR=78
79+
MAXCONCURRENCY=79
80+
RESOURCE=80
81+
INPUTPATH=81
82+
OUTPUTPATH=82
83+
ITEMSPATH=83
84+
RESULTPATH=84
85+
RESULT=85
86+
PARAMETERS=86
87+
RESULTSELECTOR=87
88+
NEXT=88
89+
END=89
90+
CAUSE=90
91+
ERROR=91
92+
RETRY=92
93+
ERROREQUALS=93
94+
INTERVALSECONDS=94
95+
MAXATTEMPTS=95
96+
BACKOFFRATE=96
97+
CATCH=97
98+
ERRORNAMEStatesALL=98
99+
ERRORNAMEStatesHeartbeatTimeout=99
100+
ERRORNAMEStatesTimeout=100
101+
ERRORNAMEStatesTaskFailed=101
102+
ERRORNAMEStatesPermissions=102
103+
ERRORNAMEStatesResultPathMatchFailure=103
104+
ERRORNAMEStatesParameterPathFailure=104
105+
ERRORNAMEStatesBranchFailed=105
106+
ERRORNAMEStatesNoChoiceMatched=106
107+
ERRORNAMEStatesIntrinsicFailure=107
108+
ERRORNAMEStatesExceedToleratedFailureThreshold=108
109+
ERRORNAMEStatesItemReaderFailed=109
110+
ERRORNAMEStatesResultWriterFailed=110
111+
ERRORNAMEStatesRuntime=111
112+
STRINGDOLLAR=112
113+
STRINGPATHCONTEXTOBJ=113
114+
STRINGPATH=114
115+
STRING=115
116+
INT=116
117+
NUMBER=117
118+
WS=118
117119
','=1
118120
':'=2
119121
'['=3
@@ -186,40 +188,42 @@ WS=116
186188
'"Seconds"'=70
187189
'"TimestampPath"'=71
188190
'"Timestamp"'=72
189-
'"ProcessorConfig"'=73
190-
'"Mode"'=74
191-
'"INLINE"'=75
192-
'"ItemProcessor"'=76
193-
'"MaxConcurrency"'=77
194-
'"Resource"'=78
195-
'"InputPath"'=79
196-
'"OutputPath"'=80
197-
'"ItemsPath"'=81
198-
'"ResultPath"'=82
199-
'"Result"'=83
200-
'"Parameters"'=84
201-
'"ResultSelector"'=85
202-
'"Next"'=86
203-
'"End"'=87
204-
'"Cause"'=88
205-
'"Error"'=89
206-
'"Retry"'=90
207-
'"ErrorEquals"'=91
208-
'"IntervalSeconds"'=92
209-
'"MaxAttempts"'=93
210-
'"BackoffRate"'=94
211-
'"Catch"'=95
212-
'"States.ALL"'=96
213-
'"States.HeartbeatTimeout"'=97
214-
'"States.Timeout"'=98
215-
'"States.TaskFailed"'=99
216-
'"States.Permissions"'=100
217-
'"States.ResultPathMatchFailure"'=101
218-
'"States.ParameterPathFailure"'=102
219-
'"States.BranchFailed"'=103
220-
'"States.NoChoiceMatched"'=104
221-
'"States.IntrinsicFailure"'=105
222-
'"States.ExceedToleratedFailureThreshold"'=106
223-
'"States.ItemReaderFailed"'=107
224-
'"States.ResultWriterFailed"'=108
225-
'"States.Runtime"'=109
191+
'"TimeoutSeconds"'=73
192+
'"TimeoutSecondsPath"'=74
193+
'"ProcessorConfig"'=75
194+
'"Mode"'=76
195+
'"INLINE"'=77
196+
'"ItemProcessor"'=78
197+
'"MaxConcurrency"'=79
198+
'"Resource"'=80
199+
'"InputPath"'=81
200+
'"OutputPath"'=82
201+
'"ItemsPath"'=83
202+
'"ResultPath"'=84
203+
'"Result"'=85
204+
'"Parameters"'=86
205+
'"ResultSelector"'=87
206+
'"Next"'=88
207+
'"End"'=89
208+
'"Cause"'=90
209+
'"Error"'=91
210+
'"Retry"'=92
211+
'"ErrorEquals"'=93
212+
'"IntervalSeconds"'=94
213+
'"MaxAttempts"'=95
214+
'"BackoffRate"'=96
215+
'"Catch"'=97
216+
'"States.ALL"'=98
217+
'"States.HeartbeatTimeout"'=99
218+
'"States.Timeout"'=100
219+
'"States.TaskFailed"'=101
220+
'"States.Permissions"'=102
221+
'"States.ResultPathMatchFailure"'=103
222+
'"States.ParameterPathFailure"'=104
223+
'"States.BranchFailed"'=105
224+
'"States.NoChoiceMatched"'=106
225+
'"States.IntrinsicFailure"'=107
226+
'"States.ExceedToleratedFailureThreshold"'=108
227+
'"States.ItemReaderFailed"'=109
228+
'"States.ResultWriterFailed"'=110
229+
'"States.Runtime"'=111

‎localstack/services/stepfunctions/asl/antlr/runtime/ASLParser.interp

Lines changed: 7 additions & 1 deletion
Large diffs are not rendered by default.

0 commit comments

Comments
 (0)
0