diff --git a/.github/workflows/test.yaml b/.github/workflows/test.yaml index ee43b31..5c7be73 100644 --- a/.github/workflows/test.yaml +++ b/.github/workflows/test.yaml @@ -79,7 +79,7 @@ jobs: if: matrix.py_version == '3.9' with: token: ${{ secrets.CODECOV_TOKEN }} - fail_ci_if_error: true + fail_ci_if_error: false verbose: true - name: Stop containers if: always() diff --git a/taskiq_nats/broker.py b/taskiq_nats/broker.py index 25b52c9..a1dc2b5 100644 --- a/taskiq_nats/broker.py +++ b/taskiq_nats/broker.py @@ -79,3 +79,4 @@ async def listen(self) -> AsyncGenerator[BrokerMessage, None]: async def shutdown(self) -> None: """Close connections to NATS.""" await self.client.close() + await super().shutdown()