diff --git a/src/StreamingDataFrames/streamingdataframes/dataframe/dataframe.py b/src/StreamingDataFrames/streamingdataframes/dataframe/dataframe.py
index 66e6b817c..fdbffaa86 100644
--- 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: