Remove unused params from StreamingDataFrame

quixio · Oct 25, 2023 · 31eb2f2 · 31eb2f2
1 parent ac5dab5
commit 31eb2f2
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/src/StreamingDataFrames/streamingdataframes/dataframe/dataframe.py b/src/StreamingDataFrames/streamingdataframes/dataframe/dataframe.py
@@ -128,12 +128,9 @@ def __init__(
         self,
         topics_in: List[Topic],
         state_manager: StateStoreManager,
-        # TODO: Do we need these params?
-        _pipeline: Pipeline = None,
-        _id: str = None,
     ):
-        self._id = _id or str(uuid.uuid4())
-        self._pipeline = _pipeline or Pipeline(_id=self.id)
+        self._id = str(uuid.uuid4())
+        self._pipeline = Pipeline(_id=self.id)
         self._real_consumer: Optional[RowConsumerProto] = None
         self._real_producer: Optional[RowProducerProto] = None
         if not topics_in: