feldera
diff --git a/‎python/feldera/connector_stats.py‎
Lines changed: 0 additions & 223 deletions b/‎python/feldera/connector_stats.py‎
Lines changed: 0 additions & 223 deletions
diff --git a/‎python/feldera/pipeline.py‎
Lines changed: 5 additions & 6 deletions b/‎python/feldera/pipeline.py‎
Lines changed: 5 additions & 6 deletions
@@ -33,8 +33,7 @@
 from feldera.rest.sql_table import SQLTable
 from feldera.rest.sql_view import SQLView
 from feldera.runtime_config import RuntimeConfig
-from feldera.connector_stats import InputConnectorStatus, OutputConnectorStatus
-from feldera.stats import PipelineStatistics
+from feldera.stats import InputEndpointStatus, OutputEndpointStatus, PipelineStatistics
 from feldera.types import CheckpointMetadata
 
 
@@ -247,21 +246,21 @@ def resume_connector(self, table_name: str, connector_name: str):
 
     def input_connector_stats(
         self, table_name: str, connector_name: str
-    ) -> InputConnectorStatus:
+    ) -> InputEndpointStatus:
         """
         Get the status of the specified input connector.
         """
-        return InputConnectorStatus.from_dict(
+        return InputEndpointStatus.from_dict(
             self.client.input_connector_stats(self.name, table_name, connector_name)
         )
 
     def output_connector_stats(
         self, view_name: str, connector_name: str
-    ) -> OutputConnectorStatus:
+    ) -> OutputEndpointStatus:
         """
         Get the status of the specified output connector.
         """
-        return OutputConnectorStatus.from_dict(
+        return OutputEndpointStatus.from_dict(
             self.client.output_connector_stats(self.name, view_name, connector_name)
         )