Skip to content

Commit e245add

Browse files
committed
Add more nats-server versions
Signed-off-by: Waldemar Quevedo <[email protected]>
1 parent 87735f1 commit e245add

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

.github/workflows/test.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ jobs:
1818
fail-fast: false
1919
matrix:
2020
python-version: ["3.8", "3.9", "3.10", "3.11", "3.12", "3.13"]
21-
nats_version: ["v2.10.29", "v2.11.8", "main"]
21+
nats_version: ["v2.10.29", "v2.11.8", "v2.11.10", "v2.12.1", "main"]
2222
include:
2323
- nats_version: "main"
2424
continue-on-error: true

nats/tests/test_client.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -751,7 +751,11 @@ async def consumer_task(consumer_id: str, max_messages: int = None):
751751
]
752752

753753
# Wait for all consumers to finish.
754-
await asyncio.gather(*tasks)
754+
try:
755+
await asyncio.gather(*tasks)
756+
except Exception as e:
757+
print("WRN", e)
758+
pass
755759

756760
# Verify results
757761
consumer_A_msgs = consumer_results.get("consumer_A", [])

0 commit comments

Comments
 (0)