From 3ecb5831541ba00189ed6d622923b46fd36e9674 Mon Sep 17 00:00:00 2001 From: linxinyuan Date: Tue, 24 Sep 2024 19:05:59 -0700 Subject: [PATCH] init --- .../main/python/core/architecture/packaging/input_manager.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/amber/src/main/python/core/architecture/packaging/input_manager.py b/core/amber/src/main/python/core/architecture/packaging/input_manager.py index 519ab448628..4a50fccea81 100644 --- a/core/amber/src/main/python/core/architecture/packaging/input_manager.py +++ b/core/amber/src/main/python/core/architecture/packaging/input_manager.py @@ -89,7 +89,7 @@ def process_data_payload( ) -> Iterator[Union[Tuple, InternalMarker]]: # special case used to yield for source op if from_ == InputManager.SOURCE_STARTER: - yield EndOfInputChannel() + yield EndOfInputPort() yield EndOfOutputPorts() return