It appears that we are not getting state updated correctly for a tap. The output from the elt run shows progress_markers, but the replication key and value are never "promoted" to the partition level in the state structure. Anyone see that before?