Update test_syslog_source_ip.py

Author: ytzur1

tests/syslog/syslog_utils.py

@@ -156,4 +156,3 @@ def capture_syslog_packets(dut, tcpdump_cmd, logging_data):
     # fetch pcap file from dut to mgmt
     dut.fetch(src=dut_pcap_filepath, dest=syslogUtilsConst.DOCKER_TMP_PATH)
     return sonic_mgmt_pcap_filepath
-

tests/syslog/test_syslog_source_ip.py

@@ -69,15 +69,15 @@
                                   "vrf_set_source_set_800"]
 SYSLOG_DEFAULT_PORT = 514
 TEST_FORWARD_FLAGS_AND_MSGS = {
-    "default": ('', ''), 
-    "teamd_": ("-t teamd_", "teamd_"), 
-    "bgp0#frr": ("-t bgp0#frr", "bgp0#frr"), 
-    "bgp0#zebra": ("-t bgp0#zebra", "bgp0#zebra"), 
-    "bgp0#staticd": ("-t bgp0#staticd", "bgp0#staticd"), 
-    "bgp0#watchfrr": ("-t bgp0#watchfrr", "bgp0#watchfrr"), 
-    "bgp0#bgpd": ("-t bgp0#bgpd", "bgp0#bgpd"), 
-    "gnmi-native": ("-t gnmi-native", "gnmi-native"), 
-    "telemetry": ("-t telemetry", "telemetry"), 
+    "default": ('', ''),
+    "teamd_": ("-t teamd_", "teamd_"),
+    "bgp0#frr": ("-t bgp0#frr", "bgp0#frr"),
+    "bgp0#zebra": ("-t bgp0#zebra", "bgp0#zebra"),
+    "bgp0#staticd": ("-t bgp0#staticd", "bgp0#staticd"),
+    "bgp0#watchfrr": ("-t bgp0#watchfrr", "bgp0#watchfrr"),
+    "bgp0#bgpd": ("-t bgp0#bgpd", "bgp0#bgpd"),
+    "gnmi-native": ("-t gnmi-native", "gnmi-native"),
+    "telemetry": ("-t telemetry", "telemetry"),
     "dialout": ("-t dialout", "dialout")}
 
 SYSLOG_THREAD_TIMEOUT = 50
@@ -592,7 +592,10 @@ def gen_tcpdump_cmd_and_capture_syslog_packets(self, routed_interfaces, port, vr
         else:
             tcpdump_interface = vrf
         tcpdump_file_name = syslogUtilsConst.DUT_PCAP_FILEPATH.format(vrf=vrf + '_neg' if neg else vrf)
-        tcpdump_cmd = f"sudo timeout {syslogUtilsConst.TCPDUMP_CAPTURE_TIME} tcpdump -i {tcpdump_interface} port {port if port else SYSLOG_DEFAULT_PORT} -w {tcpdump_file_name}"
+        tcpdump_cmd = (
+            f"sudo timeout {syslogUtilsConst.TCPDUMP_CAPTURE_TIME} tcpdump -i {tcpdump_interface}"
+            f"port {port if port else SYSLOG_DEFAULT_PORT} -w {tcpdump_file_name}"
+        )
         tcpdump_file = capture_syslog_packets(self.duthost, tcpdump_cmd, logging_data)
         return tcpdump_file
 
@@ -835,8 +838,11 @@ def test_syslog_protocol_filter_severity(self, duthosts, enum_rand_one_per_hwsku
         with allure.step("Configure include filter and verify"):
             filter_regex = 'sonic'
             logging_data = [(logger_flags, filter_regex)]
-            self.duthost.shell('sonic-db-cli CONFIG_DB hset "SYSLOG_SERVER|{0}" '
-                               '"filter_type" "include" "filter_regex" {1}'.format(default_vrf_rsyslog_ip, filter_regex))
+            self.duthost.shell(
+                'sonic-db-cli CONFIG_DB hset "SYSLOG_SERVER|{0}" '
+                '"filter_type" "include" "filter_regex" {1}'
+                .format(default_vrf_rsyslog_ip, filter_regex)
+            )
 
         with allure.step("Check interface of {} send syslog msg with include regex".format(routed_interfaces[0])):
             self.check_syslog_msg_is_sent(routed_interfaces, mgmt_interface, port, vrf_list=vrf_list,
@@ -853,8 +859,11 @@ def test_syslog_protocol_filter_severity(self, duthosts, enum_rand_one_per_hwsku
 
         with allure.step("Configure exclude filter and verify"):
             filter_regex = 'aa'
-            self.duthost.shell('sonic-db-cli CONFIG_DB hset'
-                               ' "SYSLOG_SERVER|{0}" "filter_type" "exclude" "filter_regex" {1}'.format(default_vrf_rsyslog_ip, filter_regex))
+            self.duthost.shell(
+                'sonic-db-cli CONFIG_DB hset'
+                ' "SYSLOG_SERVER|{0}" "filter_type" "exclude" "filter_regex" {1}'
+                .format(default_vrf_rsyslog_ip, filter_regex)
+            )
 
         with allure.step("Check interface of {} will not send syslog msg with exclude".format(routed_interfaces[0])):
             logging_data = [(logger_flags, filter_regex)]