adam_roderick
12/09/2021, 12:46 PMreplication_key_value
? I am tapping an API where I must sort descending, so I want replication_key_value
to be a timestamp of when I start a tap run. I set self.replication_key_value
in the stream, but the state that is emitted is not affected by thisadam_roderick
12/09/2021, 12:57 PMstate = self.get_context_state(None)
state["replication_key_value"] = .......
edgar_ramirez_mondragon
12/09/2021, 4:40 PMincrement_state
, which is part of the experimental _state
module (cc @aaronsteers)adam_roderick
12/09/2021, 8:01 PM