You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
definition: '{"Comment":"An Example State machine using Activity.","StartAt":"FirstState","States":{"FirstState":{"Type":"Task","Resource":"arn:aws:states:eu-central-1:170670752151:activity:test-step-function-worker","TimeoutSeconds":300,"HeartbeatSeconds":60,"Next":"End"}}}',
@@ -51,6 +57,7 @@ test.serial('Step function Activity Worker with 2 consecutive tasks', t => {
51
57
52
58
constworker=newStepFunctionWorker({
53
59
activityArn,
60
+
logger,
54
61
workerName: workerName+'-fn',
55
62
fn
56
63
});
@@ -98,6 +105,7 @@ test.serial('Step function with 3 poolConcurrency worker', t => {
98
105
99
106
constworker=newStepFunctionWorker({
100
107
activityArn,
108
+
logger,
101
109
workerName: workerName+'-poolConcurrency',
102
110
fn: fn2,
103
111
poolConcurrency: 3
@@ -174,6 +182,7 @@ test.serial('Step function with deprecated concurrency worker', t => {
174
182
175
183
constworker=newStepFunctionWorker({
176
184
activityArn,
185
+
logger,
177
186
workerName: workerName+'-concurrency',
178
187
fn: fn2,
179
188
concurrency: 3
@@ -249,6 +258,7 @@ test.serial('Restart the worker', t => {
249
258
250
259
constworker=newStepFunctionWorker({
251
260
activityArn,
261
+
logger,
252
262
workerName: workerName+'-restart',
253
263
fn: fn2,
254
264
poolConcurrency: 1
@@ -272,9 +282,9 @@ test.serial('Restart the worker', t => {
0 commit comments