It seems I have to reload. You are pushing commits while I am commenting. Both comments go to this line:

```
'$inc': {'derive_state.%s.%s' % (ts_key, src_stream.id) : value} 
```