Skip to content

Commit f847b41

Browse files
Update README.md
1 parent 834f570 commit f847b41

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -162,7 +162,7 @@ class CustomStreamingCommand(StreamingCommand):
162162
def stream(self, records):
163163
for index, record in enumerate(records):
164164
if index % 1 == 0:
165-
record = self.add_field(record, "odd_record", "true")
165+
self.add_field(record, "odd_record", "true")
166166
yield record
167167
```
168168

0 commit comments

Comments
 (0)