Event streaming fail for thousands of records

[ahmadRagheb]

how to reproduce : 1- data import data with 5000 or more recorded 2- the system will fail to send it all

my error log

frappe.event_streaming.doctype.event_producer.event_producer.pull_from_node Error Traceback (most recent call last): File "/home/frappe/frappe-bench/apps/frappe/frappe/utils/background_jobs.py", line 104, in execute_job method(**kwargs) File "/home/frappe/frappe-bench/apps/frappe/frappe/event_streaming/doctype/event_producer/event_producer.py", line 209, in pull_from_node updates = get_updates(producer_site, last_update, doctypes) File "/home/frappe/frappe-bench/apps/frappe/frappe/event_streaming/doctype/event_producer/event_producer.py", line 368, in get_updates 'last_update': last_update File "/home/frappe/frappe-bench/apps/frappe/frappe/frappeclient.py", line 308, in post_request res = self.post_process(res) File "/home/frappe/frappe-bench/apps/frappe/frappe/frappeclient.py", line 321, in post_process rjson = response.json() File "/home/frappe/frappe-bench/env/lib/python3.6/site-packages/requests/models.py", line 900, in json return complexjson.loads(self.text, **kwargs) File "/usr/lib/python3.6/json/init.py", line 354, in loads return _default_decoder.decode(s) File "/usr/lib/python3.6/json/decoder.py", line 339, in decode obj, end = self.raw_decode(s, idx=_w(s, 0).end()) File "/usr/lib/python3.6/json/decoder.py", line 357, in raw_decode raise JSONDecodeError("Expecting value", s, err.value) from None json.decoder.JSONDecodeError: Expecting value: line 1 column 1 (char 0)