Move output to connection utils
Signed-off-by: Katarzyna Treder <katarzyna.treder@h-partners.com>
This commit is contained in:
parent
513f006d17
commit
161cc7957a
@ -8,7 +8,7 @@ import time
|
|||||||
from datetime import timedelta
|
from datetime import timedelta
|
||||||
|
|
||||||
from core.test_run import TestRun
|
from core.test_run import TestRun
|
||||||
from test_utils.output import CmdException
|
from connection.utils.output import CmdException
|
||||||
|
|
||||||
|
|
||||||
class BaseExecutor:
|
class BaseExecutor:
|
||||||
|
@ -10,7 +10,7 @@ from datetime import timedelta
|
|||||||
from connection.base_executor import BaseExecutor
|
from connection.base_executor import BaseExecutor
|
||||||
from core.test_run import TestRun
|
from core.test_run import TestRun
|
||||||
from test_tools.fs_utils import copy
|
from test_tools.fs_utils import copy
|
||||||
from test_utils.output import Output, CmdException
|
from connection.utils.output import Output, CmdException
|
||||||
|
|
||||||
|
|
||||||
class LocalExecutor(BaseExecutor):
|
class LocalExecutor(BaseExecutor):
|
||||||
|
@ -13,7 +13,7 @@ import paramiko
|
|||||||
|
|
||||||
from connection.base_executor import BaseExecutor
|
from connection.base_executor import BaseExecutor
|
||||||
from core.test_run import TestRun, Blocked
|
from core.test_run import TestRun, Blocked
|
||||||
from test_utils.output import Output
|
from connection.utils.output import Output
|
||||||
|
|
||||||
|
|
||||||
class SshExecutor(BaseExecutor):
|
class SshExecutor(BaseExecutor):
|
||||||
|
0
connection/utils/__init__.py
Normal file
0
connection/utils/__init__.py
Normal file
@ -7,7 +7,7 @@ from time import sleep
|
|||||||
from core.test_run_utils import TestRun
|
from core.test_run_utils import TestRun
|
||||||
from storage_devices.device import Device
|
from storage_devices.device import Device
|
||||||
from test_utils import os_utils
|
from test_utils import os_utils
|
||||||
from test_utils.output import CmdException
|
from connection.utils.output import CmdException
|
||||||
|
|
||||||
|
|
||||||
class ScsiDebug:
|
class ScsiDebug:
|
||||||
|
@ -15,7 +15,7 @@ import portalocker
|
|||||||
from log.html_log_config import HtmlLogConfig
|
from log.html_log_config import HtmlLogConfig
|
||||||
from log.html_log_manager import HtmlLogManager
|
from log.html_log_manager import HtmlLogManager
|
||||||
from log.html_presentation_policy import html_policy
|
from log.html_presentation_policy import html_policy
|
||||||
from test_utils.output import Output
|
from connection.utils.output import Output
|
||||||
from test_utils.singleton import Singleton
|
from test_utils.singleton import Singleton
|
||||||
|
|
||||||
|
|
||||||
|
@ -15,7 +15,7 @@ from storage_devices.device import Device
|
|||||||
from test_tools import disk_utils, fs_utils, nvme_cli
|
from test_tools import disk_utils, fs_utils, nvme_cli
|
||||||
from test_utils import disk_finder
|
from test_utils import disk_finder
|
||||||
from test_utils.os_utils import wait
|
from test_utils.os_utils import wait
|
||||||
from test_utils.output import Output
|
from connection.utils.output import Output
|
||||||
from types.size import Unit
|
from types.size import Unit
|
||||||
|
|
||||||
|
|
||||||
|
@ -3,14 +3,13 @@
|
|||||||
# SPDX-License-Identifier: BSD-3-Clause-Clear
|
# SPDX-License-Identifier: BSD-3-Clause-Clear
|
||||||
#
|
#
|
||||||
|
|
||||||
import os
|
|
||||||
import posixpath
|
import posixpath
|
||||||
|
|
||||||
from core.test_run import TestRun
|
from core.test_run import TestRun
|
||||||
from storage_devices.device import Device
|
from storage_devices.device import Device
|
||||||
from test_tools.drbdadm import Drbdadm
|
from test_tools.drbdadm import Drbdadm
|
||||||
from test_utils.filesystem.symlink import Symlink
|
from test_utils.filesystem.symlink import Symlink
|
||||||
from test_utils.output import CmdException
|
from connection.utils.output import CmdException
|
||||||
|
|
||||||
|
|
||||||
class Drbd(Device):
|
class Drbd(Device):
|
||||||
|
@ -13,7 +13,7 @@ from core.test_run import TestRun
|
|||||||
from test_tools import fs_utils
|
from test_tools import fs_utils
|
||||||
from test_tools.dd import Dd
|
from test_tools.dd import Dd
|
||||||
from test_tools.fs_utils import readlink, parse_ls_output, ls
|
from test_tools.fs_utils import readlink, parse_ls_output, ls
|
||||||
from test_utils.output import CmdException
|
from connection.utils.output import CmdException
|
||||||
from types.size import Size, Unit
|
from types.size import Size, Unit
|
||||||
|
|
||||||
SECTOR_SIZE = 512
|
SECTOR_SIZE = 512
|
||||||
|
@ -13,7 +13,7 @@ import test_tools.fs_utils
|
|||||||
from core.test_run import TestRun
|
from core.test_run import TestRun
|
||||||
from test_tools import fs_utils
|
from test_tools import fs_utils
|
||||||
from test_utils import os_utils
|
from test_utils import os_utils
|
||||||
from test_utils.output import CmdException
|
from connection.utils.output import CmdException
|
||||||
|
|
||||||
|
|
||||||
class Fio:
|
class Fio:
|
||||||
|
@ -9,7 +9,7 @@ import os
|
|||||||
import re
|
import re
|
||||||
|
|
||||||
from core.test_run import TestRun
|
from core.test_run import TestRun
|
||||||
from test_utils.output import CmdException
|
from connection.utils.output import CmdException
|
||||||
|
|
||||||
|
|
||||||
class RpmSet:
|
class RpmSet:
|
||||||
|
@ -9,7 +9,7 @@ from core.test_run import TestRun
|
|||||||
from test_tools import disk_utils
|
from test_tools import disk_utils
|
||||||
from test_tools.fs_utils import check_if_file_exists, readlink
|
from test_tools.fs_utils import check_if_file_exists, readlink
|
||||||
from test_utils import os_utils
|
from test_utils import os_utils
|
||||||
from test_utils.output import CmdException
|
from connection.utils.output import CmdException
|
||||||
|
|
||||||
|
|
||||||
def find_disks():
|
def find_disks():
|
||||||
|
@ -4,7 +4,7 @@
|
|||||||
#
|
#
|
||||||
|
|
||||||
from core.test_run import TestRun
|
from core.test_run import TestRun
|
||||||
from test_utils.output import Output
|
from connection.utils.output import Output
|
||||||
|
|
||||||
|
|
||||||
def get_dmesg() -> str:
|
def get_dmesg() -> str:
|
||||||
|
@ -9,7 +9,7 @@ import posixpath
|
|||||||
|
|
||||||
from core.test_run import TestRun
|
from core.test_run import TestRun
|
||||||
from connection.local_executor import LocalExecutor
|
from connection.local_executor import LocalExecutor
|
||||||
from test_utils.output import CmdException
|
from connection.utils.output import CmdException
|
||||||
|
|
||||||
|
|
||||||
def __get_executor_and_repo_path(from_dut):
|
def __get_executor_and_repo_path(from_dut):
|
||||||
|
@ -5,7 +5,7 @@
|
|||||||
import re
|
import re
|
||||||
|
|
||||||
from core.test_run import TestRun
|
from core.test_run import TestRun
|
||||||
from test_utils.output import CmdException
|
from connection.utils.output import CmdException
|
||||||
|
|
||||||
SYSFS_LINE_FORMAT = r"^(\d+\s+){10,}\d+$"
|
SYSFS_LINE_FORMAT = r"^(\d+\s+){10,}\d+$"
|
||||||
PROCFS_LINE_FORMAT = r"^\d+\s+\d+\s+[\w-]+\s+" + SYSFS_LINE_FORMAT[1:]
|
PROCFS_LINE_FORMAT = r"^\d+\s+\d+\s+[\w-]+\s+" + SYSFS_LINE_FORMAT[1:]
|
||||||
|
@ -20,7 +20,7 @@ from test_tools.dd import Dd
|
|||||||
from test_tools.disk_utils import get_sysfs_path
|
from test_tools.disk_utils import get_sysfs_path
|
||||||
from test_tools.fs_utils import check_if_directory_exists, create_directory, check_if_file_exists
|
from test_tools.fs_utils import check_if_directory_exists, create_directory, check_if_file_exists
|
||||||
from test_utils.filesystem.file import File
|
from test_utils.filesystem.file import File
|
||||||
from test_utils.output import CmdException
|
from connection.utils.output import CmdException
|
||||||
from test_utils.retry import Retry
|
from test_utils.retry import Retry
|
||||||
from types.size import Size, Unit
|
from types.size import Size, Unit
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user