From 60fd42d2cd0f66af6002ad9b00a72b511c72a7f7 Mon Sep 17 00:00:00 2001 From: David Gardner Date: Wed, 7 Aug 2024 13:06:10 -0700 Subject: [PATCH] Docstring fix, and fix for removed variable [no ci] --- morpheus/stages/input/http_server_source_stage.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/morpheus/stages/input/http_server_source_stage.py b/morpheus/stages/input/http_server_source_stage.py index 6f02acb559..b88cd04af0 100644 --- a/morpheus/stages/input/http_server_source_stage.py +++ b/morpheus/stages/input/http_server_source_stage.py @@ -87,7 +87,7 @@ class HttpServerSourceStage(PreallocatorMixin, SingleOutputSource): A callable that takes the HTTP payload string as the first argument and the `lines` parameter is passed in as the second argument and returns a cudf.DataFrame. When supplied, the C++ implementation of this stage is disabled, and the Python impl is used. - message_type : type[`morpheus.messages.MessageMeta`] or type[`morpheus.messages.ControlMessage`], default `MessageMeta` + message_type : `type[MessageMeta]` or `type[ControlMessage]`, default `type[MessageMeta]` The type of message to emit. task_type : str, default = None If specified, adds the specified task to the `ControlMessage`. This parameter is only valid when `message_type` @@ -142,7 +142,6 @@ def __init__(self, self._message_type = message_type self._task_type = task_type self._task_payload = task_payload - self._request_to_task_payload_fn = request_to_task_payload_fn if (self._message_type is ControlMessage): if ((self._task_type is None) != (self._task_payload is None)):