Skip to content

Commit

Permalink
Apply suggestions from code review
Browse files Browse the repository at this point in the history
Co-authored-by: Jeffrey James <lobotmcj@gmail.com>
  • Loading branch information
pdmack and lobotmcj committed May 23, 2022
1 parent cf9f2f5 commit d023f9a
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions docs/source/developer_guide/guides/1_simple_python_stage.md
Original file line number Diff line number Diff line change
Expand Up @@ -139,12 +139,12 @@ Next, we will build a Morpheus `Config` object. We will cover setting some commo
config = Config()
```

In this example, we will use the `FileSourceStage` class to read a large file in which each line is a JSON object that represents an email message. The stage will take these lines and package them as Morpheus message objects for our pass-through stage to consume. Let's setup our source stage:
In this example, we will use the `FileSourceStage` class to read a large file in which each line is a JSON object that represents an email message. The stage will take these lines and package them as Morpheus message objects for our pass through stage to consume. Let's setup our source stage:
```python
pipeline.set_source(FileSourceStage(config, filename=input_file, iterative=False))
```

Next, we will add our new stage to the pipeline as well as a `MonitorStage` which will measure the throughput of our pass-through stage:
Next, we will add our new stage to the pipeline as well as a `MonitorStage` which will measure the throughput of our pass through stage:

```python
pipeline.add_stage(PassThruStage(config))
Expand Down

0 comments on commit d023f9a

Please sign in to comment.