Skip to content

Commit

Permalink
Lint fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
dagardner-nv committed Dec 26, 2023
1 parent 01f0fe8 commit 2ad239f
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 5 deletions.
1 change: 0 additions & 1 deletion examples/log_parsing/run.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,6 @@
from postprocessing import LogParsingPostProcessingStage

from morpheus.config import Config
from morpheus.config import CppConfig
from morpheus.config import PipelineModes
from morpheus.pipeline import LinearPipeline
from morpheus.stages.general.monitor_stage import MonitorStage
Expand Down
2 changes: 1 addition & 1 deletion morpheus/stages/inference/triton_inference_stage.py
Original file line number Diff line number Diff line change
Expand Up @@ -733,7 +733,7 @@ def supports_cpp_node(self) -> bool:

def _get_inference_worker(self, inf_queue: ProducerConsumerQueue) -> TritonInferenceWorker:
"""
Returns the worker for this stage. Authors of custom sub-classes can override this method to provide a custom
Returns the worker for this stage. Authors of custom sub-classes can override this method to provide a custom
worker.
"""

Expand Down
6 changes: 4 additions & 2 deletions tests/examples/log_parsing/test_inference.py
Original file line number Diff line number Diff line change
Expand Up @@ -259,5 +259,7 @@ def test_log_parsing_inference_stage_convert_one_response(import_mod: typing.Lis
tensors = resp_msg.memory.get_tensors()
for (tensor_name, tensor) in tensors.items():
orig_tensor = orig_tensors[tensor_name]
assert (tensor[0:offset] == orig_tensor[0:offset]).all(), f"Out of bounds values for {tensor_name}"
assert (tensor[offset + count:] == orig_tensor[offset + count:]).all(), f"Out of bounds values for {tensor_name}"

error_msg = f"Out of bounds values for {tensor_name}"
assert (tensor[0:offset] == orig_tensor[0:offset]).all(), error_msg
assert (tensor[offset + count:] == orig_tensor[offset + count:]).all(), error_msg
2 changes: 1 addition & 1 deletion tests/examples/log_parsing/test_postprocessing.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,9 +24,9 @@
from _utils import TEST_DIRS
from _utils.dataset_manager import DatasetManager
from morpheus.config import Config
from morpheus.messages import TensorMemory
from morpheus.messages import MessageMeta
from morpheus.messages import MultiResponseMessage
from morpheus.messages import TensorMemory


def build_post_proc_message(dataset_cudf: DatasetManager, log_test_data_dir: str):
Expand Down

0 comments on commit 2ad239f

Please sign in to comment.