heartbeat base support

localstack · MEPalma · Jul 14, 2023 · May 8, 2023 · May 10, 2023 · May 10, 2023
commit 1382972eee0592bb1908ef10c9632a5bd330f84a
diff --git a/localstack/services/stepfunctions/asl/antlr/ASLLexer.g4 b/localstack/services/stepfunctions/asl/antlr/ASLLexer.g4
@@ -85,6 +85,9 @@ TIMESTAMP: '"Timestamp"';
 TIMEOUTSECONDS: '"TimeoutSeconds"';
 TIMEOUTSECONDSPATH: '"TimeoutSecondsPath"';
 
+HEARTBEATSECONDS: '"HeartbeatSeconds"';
+HEARTBEATSECONDSPATH: '"HeartbeatSecondsPath"';
+
 PROCESSORCONFIG: '"ProcessorConfig"';
 MODE: '"Mode"';
 INLINE: '"INLINE"';

diff --git a/localstack/services/stepfunctions/asl/antlr/ASLParser.g4 b/localstack/services/stepfunctions/asl/antlr/ASLParser.g4
@@ -47,6 +47,8 @@ state_stmt
     | max_concurrency_decl
     | timeout_seconds_decl
     | timeout_seconds_path_decl
+    | heartbeat_seconds_decl
+    | heartbeat_seconds_path_decl
     | branches_decl
     | parameters_decl
     | retry_decl
@@ -159,6 +161,13 @@ timeout_seconds_path_decl
     : TIMEOUTSECONDSPATH COLON STRINGPATH
     ;
 
+heartbeat_seconds_decl
+    : HEARTBEATSECONDS COLON INT
+    ;
+
+heartbeat_seconds_path_decl
+    : HEARTBEATSECONDSPATH COLON STRINGPATH
+    ;
 
 payload_tmpl_decl
     : LBRACE payload_binding (COMMA payload_binding)* RBRACE

diff --git a/localstack/services/stepfunctions/asl/antlr/runtime/ASLLexer.interp b/localstack/services/stepfunctions/asl/antlr/runtime/ASLLexer.interp
diff --git a/localstack/services/stepfunctions/asl/antlr/runtime/ASLLexer.py b/localstack/services/stepfunctions/asl/antlr/runtime/ASLLexer.py
diff --git a/localstack/services/stepfunctions/asl/antlr/runtime/ASLLexer.tokens b/localstack/services/stepfunctions/asl/antlr/runtime/ASLLexer.tokens
@@ -72,50 +72,52 @@ TIMESTAMPPATH=71
 TIMESTAMP=72
 TIMEOUTSECONDS=73
 TIMEOUTSECONDSPATH=74
-PROCESSORCONFIG=75
-MODE=76
-INLINE=77
-ITEMPROCESSOR=78
-MAXCONCURRENCY=79
-RESOURCE=80
-INPUTPATH=81
-OUTPUTPATH=82
-ITEMSPATH=83
-RESULTPATH=84
-RESULT=85
-PARAMETERS=86
-RESULTSELECTOR=87
-NEXT=88
-END=89
-CAUSE=90
-ERROR=91
-RETRY=92
-ERROREQUALS=93
-INTERVALSECONDS=94
-MAXATTEMPTS=95
-BACKOFFRATE=96
-CATCH=97
-ERRORNAMEStatesALL=98
-ERRORNAMEStatesHeartbeatTimeout=99
-ERRORNAMEStatesTimeout=100
-ERRORNAMEStatesTaskFailed=101
-ERRORNAMEStatesPermissions=102
-ERRORNAMEStatesResultPathMatchFailure=103
-ERRORNAMEStatesParameterPathFailure=104
-ERRORNAMEStatesBranchFailed=105
-ERRORNAMEStatesNoChoiceMatched=106
-ERRORNAMEStatesIntrinsicFailure=107
-ERRORNAMEStatesExceedToleratedFailureThreshold=108
-ERRORNAMEStatesItemReaderFailed=109
-ERRORNAMEStatesResultWriterFailed=110
-ERRORNAMEStatesRuntime=111
-STRINGDOLLAR=112
-STRINGPATHCONTEXTOBJ=113
-STRINGPATH=114
-STRING=115
-INT=116
-NUMBER=117
-WS=118
+HEARTBEATSECONDS=75
+HEARTBEATSECONDSPATH=76
+PROCESSORCONFIG=77
+MODE=78
+INLINE=79
+ITEMPROCESSOR=80
+MAXCONCURRENCY=81
+RESOURCE=82
+INPUTPATH=83
+OUTPUTPATH=84
+ITEMSPATH=85
+RESULTPATH=86
+RESULT=87
+PARAMETERS=88
+RESULTSELECTOR=89
+NEXT=90
+END=91
+CAUSE=92
+ERROR=93
+RETRY=94
+ERROREQUALS=95
+INTERVALSECONDS=96
+MAXATTEMPTS=97
+BACKOFFRATE=98
+CATCH=99
+ERRORNAMEStatesALL=100
+ERRORNAMEStatesHeartbeatTimeout=101
+ERRORNAMEStatesTimeout=102
+ERRORNAMEStatesTaskFailed=103
+ERRORNAMEStatesPermissions=104
+ERRORNAMEStatesResultPathMatchFailure=105
+ERRORNAMEStatesParameterPathFailure=106
+ERRORNAMEStatesBranchFailed=107
+ERRORNAMEStatesNoChoiceMatched=108
+ERRORNAMEStatesIntrinsicFailure=109
+ERRORNAMEStatesExceedToleratedFailureThreshold=110
+ERRORNAMEStatesItemReaderFailed=111
+ERRORNAMEStatesResultWriterFailed=112
+    ERRORNAMEStatesRuntime=113
+STRINGDOLLAR=114
+STRINGPATHCONTEXTOBJ=115
+STRINGPATH=116
+STRING=117
+INT=118
+NUMBER=119
+WS=120
 ','=1
 ':'=2
 '['=3
@@ -190,40 +192,42 @@ WS=118
 '"Timestamp"'=72
 '"TimeoutSeconds"'=73
 '"TimeoutSecondsPath"'=74
-'"ProcessorConfig"'=75
-'"Mode"'=76
-'"INLINE"'=77
-'"ItemProcessor"'=78
-'"MaxConcurrency"'=79
-'"Resource"'=80
-'"InputPath"'=81
-'"OutputPath"'=82
-'"ItemsPath"'=83
-'"ResultPath"'=84
-'"Result"'=85
-'"Parameters"'=86
-'"ResultSelector"'=87
-'"Next"'=88
-'"End"'=89
-'"Cause"'=90
-'"Error"'=91
-'"Retry"'=92
-'"ErrorEquals"'=93
-'"IntervalSeconds"'=94
-'"MaxAttempts"'=95
-'"BackoffRate"'=96
-'"Catch"'=97
-'"States.ALL"'=98
-'"States.HeartbeatTimeout"'=99
-'"States.Timeout"'=100
-'"States.TaskFailed"'=101
-'"States.Permissions"'=102
-'"States.ResultPathMatchFailure"'=103
-'"States.ParameterPathFailure"'=104
-'"States.BranchFailed"'=105
-'"States.NoChoiceMatched"'=106
-'"States.IntrinsicFailure"'=107
-'"States.ExceedToleratedFailureThreshold"'=108
-'"States.ItemReaderFailed"'=109
-'"States.ResultWriterFailed"'=110
-'"States.Runtime"'=111
+'"HeartbeatSeconds"'=75
+'"HeartbeatSecondsPath"'=76
+'"ProcessorConfig"'=77
+'"Mode"'=78
+'"INLINE"'=79
+'"ItemProcessor"'=80
+'"MaxConcurrency"'=81
+'"Resource"'=82
+'"InputPath"'=83
+'"OutputPath"'=84
+'"ItemsPath"'=85
+'"ResultPath"'=86
+'"Result"'=87
+'"Parameters"'=88
+'"ResultSelector"'=89
+'"Next"'=90
+'"End"'=91
+'"Cause"'=92
+'"Error"'=93
+'"Retry"'=94
+'"ErrorEquals"'=95
+'"IntervalSeconds"'=96
+'"MaxAttempts"'=97
+'"BackoffRate"'=98
+'"Catch"'=99
+'"States.ALL"'=100
+'"States.HeartbeatTimeout"'=101
+'"States.Timeout"'=102
+'"States.TaskFailed"'=103
+'"States.Permissions"'=104
+'"States.ResultPathMatchFailure"'=105
+'"States.ParameterPathFailure"'=106
+'"States.BranchFailed"'=107
+'"States.NoChoiceMatched"'=108
+'"States.IntrinsicFailure"'=109
+'"States.ExceedToleratedFailureThreshold"'=110
+'"States.ItemReaderFailed"'=111
+'"States.ResultWriterFailed"'=112
+'"States.Runtime"'=113
diff --git a/localstack/services/stepfunctions/asl/antlr/runtime/ASLParser.interp b/localstack/services/stepfunctions/asl/antlr/runtime/ASLParser.interp