Commit 520fdfcc authored by Ad Schellevis's avatar Ad Schellevis

(netflow/parse) send None to mark last record

parent 95522e09
...@@ -80,3 +80,5 @@ def parse_flow(recv_stamp): ...@@ -80,3 +80,5 @@ def parse_flow(recv_stamp):
else: else:
flow_record[flow_field['target']] = None flow_record[flow_field['target']] = None
yield flow_record yield flow_record
# send None to mark last record
yield None
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment