Add documentation to LinearBoundary stages

morpheus/pipeline/linear_pipeline.py

@@ -103,6 +103,35 @@ def add_stage(self, stage: _pipeline.SinglePortStage):
         self._linear_stages.append(stage)
 
     def add_segment_boundary(self, data_type=None, as_shared_pointer=False):
+        """
+        Parameters
+        ----------
+        data_type : `data_type`
+            data type that will be passed across the segment boundary, defaults to a general python object
+            if 'data_type' has no registered edge adapters.
+
+        as_shared_pointer : `boolean`
+            Whether the data type will be wrapped in a shared pointer.
+
+        Example
+        -------
+            # Create a config and pipeline \n
+            config = Config()
+            pipe = LinearPipeline(config)
+
+            # Add a source in Segment #1 \n
+            pipe.set_source(FileSourceStage(config, filename=val_file_name, iterative=False))
+
+            # Add a segment boundary \n
+            # [Current Segment] - [Egress Boundary] ---- [Ingress Boundary] - [Next Segment]
+
+            pipe.add_segment_boundary(MessageMeta)
+
+            # Add a sink in Segment #2\n
+            pipe.add_stage(WriteToFileStage(config, filename=out_file, overwrite=False))
+
+            pipe.run()
+        """
         if (len(self._linear_stages) == 0):
             raise RuntimeError("Cannot create a segment boundary, current segment is empty.")
 

morpheus/stages/boundary/linear_boundary_stage.py

@@ -38,7 +38,7 @@ class LinearBoundaryEgressStage(SinglePortStage):
     boundary_port_id : `str`
         String indicating the name of the egress port associated with the LinearBoundaryEgressStage; allowing it to be
         paired with the corresponding ingress port.
-    data_type : `python data type instance`
+    data_type : `typing.Type`
         Data type that this Stage will accept and then output to its egress port.
 
     Example