From c22b4cecd5091e238bdd2edccce6691fd29b320c Mon Sep 17 00:00:00 2001 From: ofekisr Date: Wed, 29 Dec 2021 10:59:05 +0200 Subject: [PATCH] fix: failed mypy --- .github/workflows/superset-python-misc.yml | 5 ++++- superset/utils/async_query_manager.py | 4 +--- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/.github/workflows/superset-python-misc.yml b/.github/workflows/superset-python-misc.yml index 7f9ef14994b1f..39c52c51bb8ce 100644 --- a/.github/workflows/superset-python-misc.yml +++ b/.github/workflows/superset-python-misc.yml @@ -66,7 +66,9 @@ jobs: with: python-version: ${{ matrix.python-version }} cache: 'pip' - cache-dependency-path: 'requirements/integration.txt' + cache-dependency-path: | + requirements/base.txt + requirements/integration.txt - name: Install dependencies uses: ./.github/actions/cached-dependencies with: @@ -74,6 +76,7 @@ jobs: apt-get-install pip-upgrade pip install wheel + pip install -r requirements/base.txt pip install -r requirements/integration.txt - name: pre-commit run: pre-commit run --all-files diff --git a/superset/utils/async_query_manager.py b/superset/utils/async_query_manager.py index b197a853cd9c6..a026fd6f3f3d7 100644 --- a/superset/utils/async_query_manager.py +++ b/superset/utils/async_query_manager.py @@ -176,9 +176,7 @@ def read_events( ) -> List[Optional[Dict[str, Any]]]: stream_name = f"{self._stream_prefix}{channel}" start_id = increment_id(last_id) if last_id else "-" - results = self._redis.xrange( # type: ignore - stream_name, start_id, "+", self.MAX_EVENT_COUNT - ) + results = self._redis.xrange(stream_name, start_id, "+", self.MAX_EVENT_COUNT) return [] if not results else list(map(parse_event, results)) def update_job(