diff --git a/src/ska_tango_base/base/reference_component_manager.py b/src/ska_tango_base/base/reference_component_manager.py index 0326d822fd20ac0b8d1b7a0b145f21898aaa6c1f..d69afb14f8abb0d2fa0b00d6bb6373ccd26a8dd0 100644 --- a/src/ska_tango_base/base/reference_component_manager.py +++ b/src/ska_tango_base/base/reference_component_manager.py @@ -395,7 +395,7 @@ class ReferenceBaseComponentManager(BaseComponentManager): class QueueWorkerComponentManager(BaseComponentManager): - """A component manager that configres the queue manager.""" + """A component manager that configures the queue manager.""" def __init__( self, diff --git a/src/ska_tango_base/base/task_queue_manager.py b/src/ska_tango_base/base/task_queue_manager.py index 6c19728317ab09e600b4cd3f3c7fe7996765409c..3d70b74f960a34417f2563ebd49c419c67b52a21 100644 --- a/src/ska_tango_base/base/task_queue_manager.py +++ b/src/ska_tango_base/base/task_queue_manager.py @@ -1,10 +1,10 @@ """ This module provides a QueueManager, TaskResult and QueueTask classes. -* **TaskUniqueId**: is a convenience `dataclass` for parsing and generating the IDs used +* **TaskUniqueId**: is a convenience class for parsing and generating the IDs used to identify the tasks. -* **TaskResult**: is a convenience `dataclass` for parsing and formatting the +* **TaskResult**: is a convenience class for parsing and formatting the results of a task. * **QueueTask**: is a class that instances of which can be added to the queue for execution diff --git a/tests/long_running_tasks/test_reference_base_device.py b/tests/long_running_tasks/test_reference_base_device.py index 8e31122266b7671d2d6e238546b24cb685a84c49..470c5e52ffb3e141009903367dbf266a18d5fa9b 100644 --- a/tests/long_running_tasks/test_reference_base_device.py +++ b/tests/long_running_tasks/test_reference_base_device.py @@ -33,7 +33,7 @@ class TestCommands: proxy.Short(1) # Wait for a result, if the task does not abort, we'll time out here while not proxy.longRunningCommandResult: - pass + time.sleep(0.1) result = TaskResult.from_task_result(proxy.longRunningCommandResult) assert result.result_code == ResultCode.OK @@ -48,7 +48,7 @@ class TestCommands: proxy.NonAbortingLongRunning(0.01) # Wait for a result, if the task does not abort, we'll time out here while not proxy.longRunningCommandResult: - pass + time.sleep(0.1) result = TaskResult.from_task_result(proxy.longRunningCommandResult) assert result.result_code == ResultCode.OK assert ( @@ -68,12 +68,12 @@ class TestCommands: unique_id, _ = proxy.AbortingLongRunning(0.5) # Wait for the task to be in progress while not proxy.longRunningCommandStatus: - pass + time.sleep(0.1) # Abort the tasks proxy.AbortCommands() # Wait for a result, if the task does not abort, we'll time out here while not proxy.longRunningCommandResult: - pass + time.sleep(0.1) result = TaskResult.from_task_result(proxy.longRunningCommandResult) assert result.unique_id == unique_id assert result.result_code == ResultCode.ABORTED @@ -87,7 +87,7 @@ class TestCommands: with DeviceTestContext(class_name, process=True) as proxy: unique_id, _ = proxy.LongRunningException() while not proxy.longRunningCommandResult: - pass + time.sleep(0.1) result = TaskResult.from_task_result(proxy.longRunningCommandResult) assert result.unique_id == unique_id assert result.result_code == ResultCode.FAILED