mirror of
https://github.com/espressif/esp-mqtt.git
synced 2026-11-01 12:06:37 +00:00
ci: Change tag used in tests
This commit is contained in:
@@ -10,7 +10,7 @@ from pytest_embedded import Dut
|
||||
from pytest_embedded_idf.utils import idf_parametrize
|
||||
|
||||
|
||||
@pytest.mark.eth_ip101
|
||||
@pytest.mark.eth_cfg_default
|
||||
@idf_parametrize("target", ["esp32"], indirect=["target"])
|
||||
def test_examples_protocol_mqtt5(dut: Dut) -> None:
|
||||
"""
|
||||
|
||||
@@ -64,7 +64,7 @@ def on_message(client, userdata, msg): # type: (mqtt.Client, tuple, mqtt.client
|
||||
message_log += "Received data:" + msg.topic + " " + payload + "\n"
|
||||
|
||||
|
||||
@pytest.mark.eth_ip101
|
||||
@pytest.mark.eth_cfg_default
|
||||
@idf_parametrize("target", ["esp32"], indirect=["target"])
|
||||
def test_examples_protocol_mqtt_ssl(dut): # type: (Dut) -> None
|
||||
broker_url = ""
|
||||
|
||||
@@ -53,7 +53,7 @@ def mqqt_server_sketch(my_ip, port): # type: (str, str) -> None
|
||||
logging.info("server closed")
|
||||
|
||||
|
||||
@pytest.mark.eth_ip101
|
||||
@pytest.mark.eth_cfg_default
|
||||
@idf_parametrize("target", ["esp32"], indirect=["target"])
|
||||
def test_examples_protocol_mqtt_qos1(dut: Dut) -> None:
|
||||
global msgid
|
||||
|
||||
@@ -45,7 +45,7 @@ def on_message(client, userdata, msg): # type: (mqtt.Client, tuple, mqtt.client
|
||||
message_log += "Received data:" + msg.topic + " " + payload + "\n"
|
||||
|
||||
|
||||
@pytest.mark.eth_ip101
|
||||
@pytest.mark.eth_cfg_default
|
||||
@idf_parametrize("target", ["esp32"], indirect=["target"])
|
||||
def test_examples_protocol_mqtt_ws(dut): # type: (Dut) -> None
|
||||
broker_url = ""
|
||||
|
||||
@@ -47,7 +47,7 @@ def on_message(client, userdata, msg): # type: (mqtt.Client, tuple, mqtt.client
|
||||
message_log += "Received data:" + msg.topic + " " + payload + "\n"
|
||||
|
||||
|
||||
@pytest.mark.eth_ip101
|
||||
@pytest.mark.eth_cfg_default
|
||||
@idf_parametrize("target", ["esp32"], indirect=["target"])
|
||||
def test_examples_protocol_mqtt_wss(dut): # type: (Dut) -> None # type: ignore
|
||||
broker_url = ""
|
||||
|
||||
+3
-2
@@ -16,8 +16,9 @@ filterwarnings =
|
||||
junit_family = xunit1
|
||||
|
||||
env_markers =
|
||||
eth_ip101: Ethernet IP101 PHY required for test
|
||||
eth_ip101_stress: Ethernet IP101 PHY required for stress test
|
||||
eth_cfg_default: Default Ethernet configuration required for test
|
||||
eth_cfg_default_stress: Default Ethernet configuration required for stress test
|
||||
eth_ip101: ESP32-Ethernet-Kit required; OpenOCD coverage dump
|
||||
generic: applicable to generic ESP devices
|
||||
|
||||
# log related
|
||||
|
||||
@@ -5,7 +5,7 @@ from pytest_embedded import Dut
|
||||
from pytest_embedded_idf.utils import idf_parametrize
|
||||
|
||||
|
||||
@pytest.mark.eth_ip101
|
||||
@pytest.mark.eth_cfg_default
|
||||
@idf_parametrize("target", ["esp32"], indirect=["target"])
|
||||
def test_mqtt_client(dut: Dut) -> None:
|
||||
dut.expect_unity_test_output()
|
||||
|
||||
@@ -5,7 +5,7 @@ from pytest_embedded import Dut
|
||||
from pytest_embedded_idf.utils import idf_parametrize
|
||||
|
||||
|
||||
@pytest.mark.eth_ip101
|
||||
@pytest.mark.eth_cfg_default
|
||||
@idf_parametrize("target", ["esp32"], indirect=["target"])
|
||||
def test_mqtt5_client(dut: Dut) -> None:
|
||||
dut.expect_unity_test_output()
|
||||
|
||||
@@ -257,7 +257,7 @@ def run_cases(dut: Dut, uri: str, cases: Dict[str, int]) -> None:
|
||||
dut.write("destroy")
|
||||
|
||||
|
||||
@pytest.mark.eth_ip101
|
||||
@pytest.mark.eth_cfg_default
|
||||
@idf_parametrize("target", ["esp32"], indirect=["target"])
|
||||
def test_mqtt_connect(
|
||||
dut: Dut,
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
# SPDX-FileCopyrightText: 2023-2025 Espressif Systems (Shanghai) CO LTD
|
||||
# SPDX-FileCopyrightText: 2023-2026 Espressif Systems (Shanghai) CO LTD
|
||||
# SPDX-License-Identifier: Unlicense OR CC0-1.0
|
||||
import contextlib
|
||||
import difflib
|
||||
@@ -371,7 +371,7 @@ test_cases = make_cases(transport_cases, get_scenarios())
|
||||
stress_test_cases = make_cases(transport_cases, stress_scenarios)
|
||||
|
||||
|
||||
@pytest.mark.eth_ip101
|
||||
@pytest.mark.eth_cfg_default
|
||||
@pytest.mark.parametrize(
|
||||
"test_case", test_cases, ids=[generate_test_id(case) for case in test_cases]
|
||||
)
|
||||
@@ -385,7 +385,7 @@ def test_mqtt_publish(dut: Dut, test_case: Any) -> None:
|
||||
run_publish_test_case(dut, publish_cfg)
|
||||
|
||||
|
||||
@pytest.mark.eth_ip101_stress
|
||||
@pytest.mark.eth_cfg_default_stress
|
||||
@pytest.mark.nightly_run
|
||||
@pytest.mark.parametrize(
|
||||
"test_case",
|
||||
@@ -405,7 +405,7 @@ def test_mqtt_publish_stress(dut: Dut, test_case: Any) -> None:
|
||||
local_test_cases = make_cases(local_broker_supported_transports, local_broker_scenarios)
|
||||
|
||||
|
||||
@pytest.mark.eth_ip101
|
||||
@pytest.mark.eth_cfg_default
|
||||
@pytest.mark.parametrize(
|
||||
"test_case",
|
||||
local_test_cases,
|
||||
|
||||
Reference in New Issue
Block a user