[Bug]: Pushing error to error stream: None

[george0st]

MLRun Version checks

• I have checked that this issue has not already been reported.

• I have confirmed this bug exists on the latest version of MLRun CE.

Reproducible Example

The error happened from time to time, it is hard to simulate, but I hope that exception detail can help.

Issue Description

2024-04-01 12:12:50,744 [error] Pushing error to error stream: None
Traceback (most recent call last):
File "C:\Python\qgate-sln-mlrun\venv\lib\site-packages\storey\flow.py", line 212, in _do_and_recover
return await self._do(event)
File "C:\Python\qgate-sln-mlrun\venv\lib\site-packages\storey\flow.py", line 1040, in _do
await self._emit_batch(key)
File "C:\Python\qgate-sln-mlrun\venv\lib\site-packages\storey\flow.py", line 1071, in _emit_batch
del self._batch_events[batch_key]
KeyError: None

Expected Behavior

Without the exception

Installation OS

Windows

Installation Method

Docker

Python Version

3.9.10

MLRun Version

1.6.2

Additional Information

No response