chore: Re-enable asnyc event API tests (#32062)
This commit is contained in:
parent
468bb5f47a
commit
101d3fa78d
|
|
@ -17,20 +17,17 @@
|
||||||
from typing import Any, Optional, Type
|
from typing import Any, Optional, Type
|
||||||
from unittest import mock
|
from unittest import mock
|
||||||
|
|
||||||
import pytest
|
|
||||||
|
|
||||||
from superset.async_events.cache_backend import (
|
from superset.async_events.cache_backend import (
|
||||||
RedisCacheBackend,
|
RedisCacheBackend,
|
||||||
RedisSentinelCacheBackend,
|
RedisSentinelCacheBackend,
|
||||||
)
|
)
|
||||||
from superset.extensions import async_query_manager
|
from superset.extensions import async_query_manager, async_query_manager_factory
|
||||||
from superset.utils import json
|
from superset.utils import json
|
||||||
from tests.integration_tests.base_tests import SupersetTestCase
|
from tests.integration_tests.base_tests import SupersetTestCase
|
||||||
from tests.integration_tests.constants import ADMIN_USERNAME
|
from tests.integration_tests.constants import ADMIN_USERNAME
|
||||||
from tests.integration_tests.test_app import app
|
from tests.integration_tests.test_app import app
|
||||||
|
|
||||||
|
|
||||||
@pytest.skip(reason="Needs to investigate this test", allow_module_level=True)
|
|
||||||
class TestAsyncEventApi(SupersetTestCase):
|
class TestAsyncEventApi(SupersetTestCase):
|
||||||
UUID = "943c920-32a5-412a-977d-b8e47d36f5a4"
|
UUID = "943c920-32a5-412a-977d-b8e47d36f5a4"
|
||||||
|
|
||||||
|
|
@ -41,7 +38,7 @@ class TestAsyncEventApi(SupersetTestCase):
|
||||||
|
|
||||||
def run_test_with_cache_backend(self, cache_backend_cls: Type[Any], test_func):
|
def run_test_with_cache_backend(self, cache_backend_cls: Type[Any], test_func):
|
||||||
app._got_first_request = False
|
app._got_first_request = False
|
||||||
async_query_manager.init_app(app)
|
async_query_manager_factory.init_app(app)
|
||||||
|
|
||||||
# Create a mock cache backend instance
|
# Create a mock cache backend instance
|
||||||
mock_cache = mock.Mock(spec=cache_backend_cls)
|
mock_cache = mock.Mock(spec=cache_backend_cls)
|
||||||
|
|
@ -130,7 +127,7 @@ class TestAsyncEventApi(SupersetTestCase):
|
||||||
|
|
||||||
def test_events_no_login(self):
|
def test_events_no_login(self):
|
||||||
app._got_first_request = False
|
app._got_first_request = False
|
||||||
async_query_manager.init_app(app)
|
async_query_manager_factory.init_app(app)
|
||||||
rv = self.fetch_events()
|
rv = self.fetch_events()
|
||||||
assert rv.status_code == 401
|
assert rv.status_code == 401
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue