Missing sensor state for rebalance #1

[haoyun]

Checklist

• I have included information about relevant versions
• I have verified that the issue persists when using the master branch of Faust.

Steps to reproduce

MWE:

import faust

app = faust.App('myapp')

if __name__ == "__main__":
    app.main()

python test.py worker

Expected behavior

no warnning

Actual behavior

starting➢ 😊
◦[2021-01-22 23:50:16,167] [414000] [WARNING] [^-App]: Missing sensor state for rebalance #1 
[2021-01-22 23:50:16,181] [414000] [WARNING] [^-App]: Missing sensor state for rebalance #1 

The same warning also appeared in #44.

Full traceback

Versions

• Python version 3.8.5
• Faust version 0.4.3
• Operating system Fedora 32 5.10.8-100.fc32.x86_64
• Kafka version 2.13-2.6.0
• RocksDB version (if applicable)

---

This was introduced in 0.2.0. It won't happen in 0.1.1. The signal

faust/faust/tables/recovery.py

Line 241 in 5cce145

self.signal_recovery_start.set()

was changed from reset to start in 0.2.0, somehow causing

faust/faust/app/base.py

Lines 1611 to 1612 in fda7e52

	finally:
	self._rebalancing_sensor_state = None

clears the sensor state.