diff --git a/examples/diagrams/analyze_pipeline.py b/examples/diagrams/analyze_pipeline.py index bbc59c59..802f9511 100644 --- a/examples/diagrams/analyze_pipeline.py +++ b/examples/diagrams/analyze_pipeline.py @@ -42,7 +42,11 @@ def parse_log(filepath): try: events.append(json.loads(line)) except json.JSONDecodeError: - pass + print( + f"Warning: skipping malformed JSONL line in {filepath}: " + f"{line[:200]!r}", + file=sys.stderr, + ) return events diff --git a/examples/diagrams/analyze_v2.py b/examples/diagrams/analyze_v2.py index cd28b4e4..02198fc6 100644 --- a/examples/diagrams/analyze_v2.py +++ b/examples/diagrams/analyze_v2.py @@ -46,7 +46,11 @@ def parse_log(filepath): try: events.append(json.loads(line)) except json.JSONDecodeError: - pass + print( + f"Warning: skipping malformed JSONL line in {filepath}: " + f"{line[:200]!r}", + file=sys.stderr, + ) return events