pipeline.state_sync
mark_state_extracted
def mark_state_extracted(state: TPipelineState, hash_: str) -> None
Marks state as extracted by setting last extracted hash to hash_ (which is current version_hash)
_last_extracted_hash
is kept locally and never synced with the destination
force_state_extract
def force_state_extract(state: TPipelineState) -> None
Forces state
to be extracted by removing local information on the most recent extraction