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():
646
646
647
647
@mark .asyncio
648
648
async def should_handle_error_during_execution_of_source_event ():
649
- async def subscribe_fn (_event , _info ):
649
+ async def subscribe_fn (_data , _info ):
650
650
yield {"email" : {"subject" : "Hello" }}
651
651
yield {"email" : {"subject" : "Goodbye" }}
652
652
yield {"email" : {"subject" : "Bonjour" }}
@@ -696,7 +696,7 @@ def resolve_fn(event, _info):
696
696
697
697
@mark .asyncio
698
698
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 ):
700
700
yield {"email" : {"subject" : "Hello" }}
701
701
raise RuntimeError ("test error" )
702
702
@@ -733,7 +733,7 @@ def resolve_fn(event, _info):
733
733
734
734
@mark .asyncio
735
735
async def should_work_with_async_resolve_function ():
736
- async def subscribe_fn (_event , _info ):
736
+ async def subscribe_fn (_data , _info ):
737
737
yield {"email" : {"subject" : "Hello" }}
738
738
739
739
async def resolve_fn (event , _info ):
You can’t perform that action at this time.
0 commit comments