File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -646,7 +646,7 @@ async def event_order_is_correct_for_multiple_publishes():
646646
647647 @mark .asyncio
648648 async def should_handle_error_during_execution_of_source_event ():
649- async def subscribe_fn (_event , _info ):
649+ async def subscribe_fn (_data , _info ):
650650 yield {"email" : {"subject" : "Hello" }}
651651 yield {"email" : {"subject" : "Goodbye" }}
652652 yield {"email" : {"subject" : "Bonjour" }}
@@ -696,7 +696,7 @@ def resolve_fn(event, _info):
696696
697697 @mark .asyncio
698698 async def should_pass_through_error_thrown_in_source_event_stream ():
699- async def subscribe_fn (_event , _info ):
699+ async def subscribe_fn (_data , _info ):
700700 yield {"email" : {"subject" : "Hello" }}
701701 raise RuntimeError ("test error" )
702702
@@ -733,7 +733,7 @@ def resolve_fn(event, _info):
733733
734734 @mark .asyncio
735735 async def should_work_with_async_resolve_function ():
736- async def subscribe_fn (_event , _info ):
736+ async def subscribe_fn (_data , _info ):
737737 yield {"email" : {"subject" : "Hello" }}
738738
739739 async def resolve_fn (event , _info ):
You can’t perform that action at this time.
0 commit comments