Hello everyone! I am trying to implement Incremental replication to a child stream, but I am struggling to get the replication_key_value for each substream call. What is the most recommended way to get the right partition to read the correct replication_key_value? Besides, it is possible to read a state file when using VSCode Debbuging? I tried to add --state <state_path> in args (in debugger lauch file), but did not work.

Hi @cesar_rubim! The

get_starting_timestamp

and

get_starting_replication_key_value

methods will get the state for the right partition when passed the partition context dict, which should be available in the scope of most methods where you’d need it.

but did not work.

Can you expand a bit on what happened? Did it fail or only seemed to fail to read the state from the file?

Actually i tried to use both methods passing context, but maybe something was incorrect in my code. About VSCode, In lauch.json, i added the args "--state", "<file_path>", but when i tried to get the content of self.partitions variable, the content of the partition present in state.json was not there