Skip to content

chore: Skip self managed kafka tests #2461

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 3 commits into from
Aug 3, 2022
+19 −12
Merged

chore: Skip self managed kafka tests #2461

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
7ddc2ba
Skip self managed kafka tests
qingchm Aug 3, 2022
01dfec2
Black reformatting
qingchm Aug 3, 2022
7a897be
Add service names for exclusion list
qingchm Aug 3, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 10 additions & 0 deletions integration/combination/test_function_with_self_managed_kafka.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,8 +1,18 @@
import pytest

from integration.helpers.base_test import BaseTest
from integration.helpers.resource import current_region_not_included

from integration.config.service_names import SELF_MANAGED_KAFKA
from parameterized import parameterized


@skipIf(
current_region_not_included([SELF_MANAGED_KAFKA]),
"SelfManagedKafka testing is not performed in this testing region",
)
class TestFunctionWithSelfManagedKafka(BaseTest):
@pytest.mark.flaky(reruns=5)
@parameterized.expand(
[
"combination/function_with_self_managed_kafka",
Expand Down
5 changes: 5 additions & 0 deletions integration/config/service_names.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,3 +24,8 @@
ARM = "ARM"
EFS = "EFS"
S3_EVENTS = "S3Events"
SELF_MANAGED_KAFKA = "SelfManagedKafka"
SECRET_MANAGER = "SecretsManager"
STATE_MACHINE = "StepFunctions"
LAMBDA_URL = "LambdaUrl"
EVENT_INVOKE_CONFIG = "EventInvokeConfig"
16 changes: 4 additions & 12 deletions integration/single/test_function_with_http_api_and_auth.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,27 +1,19 @@
import logging
from unittest.case import skipIf

from tenacity import stop_after_attempt, retry_if_exception_type, after_log, wait_exponential, retry, wait_random
import pytest

from integration.helpers.base_test import BaseTest
from integration.helpers.resource import current_region_does_not_support
from integration.config.service_names import HTTP_API

LOG = logging.getLogger(__name__)


@skipIf(current_region_does_not_support(["HttpApi"]), "HttpApi is not supported in this testing region")
@skipIf(current_region_does_not_support([HTTP_API]), "HttpApi is not supported in this testing region")
class TestFunctionWithHttpApiAndAuth(BaseTest):
"""
AWS::Lambda::Function tests with http api events and auth
"""

@retry(
stop=stop_after_attempt(5),
wait=wait_exponential(multiplier=1, min=4, max=10) + wait_random(0, 1),
retry=retry_if_exception_type(AssertionError),
after=after_log(LOG, logging.WARNING),
reraise=True,
)
@pytest.mark.flaky(reruns=5)
def test_function_with_http_api_and_auth(self):
# If the request is not signed, which none of the below are, IAM will respond with a "Forbidden" message.
# We are not testing that IAM auth works here, we are simply testing if it was applied.
Expand Down