fix sim tests

winglang · Aug 15, 2023 · fc9dcd1 · fc9dcd1
1 parent 4f36128
commit fc9dcd1
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 9 deletions.
diff --git a/libs/wingsdk/test/target-sim/__snapshots__/queue.test.ts.snap b/libs/wingsdk/test/target-sim/__snapshots__/queue.test.ts.snap
@@ -79,7 +79,7 @@ exports[`messages are not requeued if the function fails after retention timeout
   "wingsdk.cloud.Queue created.",
   "wingsdk.sim.EventMapping created.",
   "Invoke (payload=\\"{\\\\\\"messages\\\\\\":[]}\\").",
-  "Push (message=BAD MESSAGE).",
+  "Push (messages=BAD MESSAGE).",
   "Sending messages (messages=[\\"BAD MESSAGE\\"], subscriber=sim-1).",
   "Invoke (payload=\\"{\\\\\\"messages\\\\\\":[\\\\\\"BAD MESSAGE\\\\\\"]}\\").",
   "Subscriber error - returning 1 messages to queue: ERROR",
@@ -311,7 +311,7 @@ exports[`messages are not requeued if the function fails before timeout 1`] = `
   "wingsdk.cloud.Queue created.",
   "wingsdk.sim.EventMapping created.",
   "Invoke (payload=\\"{\\\\\\"messages\\\\\\":[]}\\").",
-  "Push (message=BAD MESSAGE).",
+  "Push (messages=BAD MESSAGE).",
   "Sending messages (messages=[\\"BAD MESSAGE\\"], subscriber=sim-1).",
   "Invoke (payload=\\"{\\\\\\"messages\\\\\\":[\\\\\\"BAD MESSAGE\\\\\\"]}\\").",
   "Subscriber error - returning 1 messages to queue: ERROR",
@@ -543,7 +543,7 @@ exports[`messages are requeued if the function fails after timeout 1`] = `
   "wingsdk.cloud.Queue created.",
   "wingsdk.sim.EventMapping created.",
   "Invoke (payload=\\"{\\\\\\"messages\\\\\\":[]}\\").",
-  "Push (message=BAD MESSAGE).",
+  "Push (messages=BAD MESSAGE).",
   "Sending messages (messages=[\\"BAD MESSAGE\\"], subscriber=sim-1).",
   "Invoke (payload=\\"{\\\\\\"messages\\\\\\":[\\\\\\"BAD MESSAGE\\\\\\"]}\\").",
   "Subscriber error - returning 1 messages to queue: ERROR",
@@ -776,8 +776,8 @@ exports[`queue batch size of 2, purge the queue 1`] = `
 [
   "wingsdk.cloud.TestRunner created.",
   "wingsdk.cloud.Queue created.",
-  "Push (message=A).",
-  "Push (message=B).",
+  "Push (messages=A).",
+  "Push (messages=B).",
   "ApproxSize ().",
   "Purge ().",
   "ApproxSize ().",
@@ -1100,8 +1100,7 @@ exports[`queue with one subscriber, default batch size of 1 1`] = `
   "wingsdk.cloud.Function created.",
   "wingsdk.cloud.Queue created.",
   "wingsdk.sim.EventMapping created.",
-  "Push (message=A).",
-  "Push (message=B).",
+  "Push (messages=A,B).",
   "Sending messages (messages=[\\"A\\"], subscriber=sim-1).",
   "Sending messages (messages=[\\"B\\"], subscriber=sim-1).",
   "wingsdk.sim.EventMapping deleted.",

diff --git a/libs/wingsdk/test/target-sim/queue.test.ts b/libs/wingsdk/test/target-sim/queue.test.ts
@@ -183,7 +183,7 @@ test("messages are not requeued if the function fails before timeout", async ()
       .map((trace) => trace.data.message)
   ).toEqual([
     "wingsdk.cloud.Queue created.",
-    "Push (message=BAD MESSAGE).",
+    "Push (messages=BAD MESSAGE).",
     'Sending messages (messages=["BAD MESSAGE"], subscriber=sim-1).',
     "Subscriber error - returning 1 messages to queue: ERROR",
     "wingsdk.cloud.Queue deleted.",
@@ -226,7 +226,7 @@ test("messages are not requeued if the function fails after retention timeout",
       .map((trace) => trace.data.message)
   ).toEqual([
     "wingsdk.cloud.Queue created.",
-    "Push (message=BAD MESSAGE).",
+    "Push (messages=BAD MESSAGE).",
     'Sending messages (messages=["BAD MESSAGE"], subscriber=sim-1).',
     "Subscriber error - returning 1 messages to queue: ERROR",
     "wingsdk.cloud.Queue deleted.",