Lee-W commented on code in PR #67523:
URL: https://github.com/apache/airflow/pull/67523#discussion_r3413799563
##########
airflow-core/tests/unit/jobs/test_triggerer_job.py:
##########
@@ -901,12 +910,107 @@ async def _drive():
events = list(trigger_runner.events)
assert len(events) == 1
- trigger_id, event = events[0]
+ trigger_id, event, _seq = events[0]
assert trigger_id == 1
assert event.payload == {"region": "us"}
# Group is torn down on unsubscribe.
assert trigger_runner._shared_streams._groups == {}
+ def test_shared_stream_ack_mode_integration(self, session) -> None:
Review Comment:
fixed. thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
