Fix tests

onna · Aug 11, 2023 · 9a9fe49 · 9a9fe49
1 parent 9589d08
commit 9a9fe49
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/tests/acceptance/test_pubsub.py b/tests/acceptance/test_pubsub.py
@@ -287,8 +287,8 @@ async def noop_ng(data: Foo):
         raise Exception("Unhandled Exception")
 
     async with app:
-        await app.publish(stream_id, Foo(bar=1))
-        await app.publish(stream_id, Foo(bar=1))
+        await app.publish(stream_id, Foo(bar="1"))
+        await app.publish(stream_id, Foo(bar="1"))
         await app.flush()
 
         # it fails
@@ -311,7 +311,7 @@ async def noop_ok(data: Foo):
         probe("ok", data)
 
     async with app:
-        await app.publish(stream_id, Foo(bar=2))
+        await app.publish(stream_id, Foo(bar="2"))
         await app.flush()
 
         await app.consume_for(3, seconds=10)
@@ -351,8 +351,8 @@ async def noop(data: Foo):
         probe(data)
 
     async with app:
-        await app.publish(stream_id, Foo(bar=1))
-        await app.publish(stream_id, Foo(bar=2))
+        await app.publish(stream_id, Foo(bar="1"))
+        await app.publish(stream_id, Foo(bar="2"))
         await app.flush()
 
         await app.consume_for(2, seconds=5)