[superset] branch master updated: fix: failed mypy (#17886)

[am...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

amitmiran pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/superset.git


The following commit(s) were added to refs/heads/master by this push:
     new ef57bd1  fix: failed mypy (#17886)
ef57bd1 is described below

commit ef57bd19024e2e8bac64d5475e74b7d0c215872d
Author: ofekisr <35...@users.noreply.github.com>
AuthorDate: Wed Dec 29 16:05:53 2021 +0200

    fix: failed mypy (#17886)
---
 .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 7f9ef14..39c52c5 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 b197a85..a026fd6 100644
--- a/superset/utils/async_query_manager.py
+++ b/superset/utils/async_query_manager.py
@@ -176,9 +176,7 @@ class AsyncQueryManager:
     ) -> 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(