(self, obj: dict)
| 101 | f.write(json.dumps(meta, ensure_ascii=False, indent=2)) |
| 102 | |
| 103 | def write_event(self, obj: dict): |
| 104 | self.fp_events.write(json.dumps(obj, ensure_ascii=False) + "\n") |
| 105 | self._cnt += 1 |
| 106 | if self._cnt % self.flush_every == 0: |
| 107 | self.fp_events.flush() |
| 108 | |
| 109 | def close(self): |
| 110 | try: |