Checklist
Steps to reproduce
Using a faust[fast], values stored in a Table with HoppingWindow are not retrievable via the .value() function.
Inspecting the RocksDB tables via ldb, the keys (given that we store an integer as key) are on the form:
[621, [1603100040.0, 1603100099.9]]
However, when trying to retrieve the data, the key asked for is on the form:
[621, [1603100040, 1603100099.9]]
This only happens when faust has been cythonized. When running with NO_CYTHON=True, the problem disappears.
The root cause seems to be the Cython implementation of HoppingWindow.ranges returning a tuple (int, float) instead of (float, float).
Possibly related to #223, #510, but not sure about that.
Versions
- Python version: 3.8.5
- Faust version: master
- Operating system: Linux
- Kafka version: N/A
- RocksDB version: 5.17.2-3 (Ubuntu package)
Checklist
masterbranch of Faust.Steps to reproduce
Using a faust[fast], values stored in a Table with HoppingWindow are not retrievable via the
.value()function.Inspecting the RocksDB tables via
ldb, the keys (given that we store an integer as key) are on the form:[621, [1603100040.0, 1603100099.9]]However, when trying to retrieve the data, the key asked for is on the form:
[621, [1603100040, 1603100099.9]]This only happens when faust has been cythonized. When running with NO_CYTHON=True, the problem disappears.
The root cause seems to be the Cython implementation of HoppingWindow.ranges returning a tuple (int, float) instead of (float, float).
Possibly related to #223, #510, but not sure about that.
Versions