@@ -120,22 +120,22 @@ def init_change_tracking(self, table_config, last_known_sync_version):
120120 self .database_engine .execute (text (init_change_tracking_sql ).execution_options (autocommit = True ))
121121
122122 # in the following we determine:
123- # a) the current sync version - sourced straight up from the source db
123+ # a) the current sync version - sourced straight up from the source db.
124124 # b) the last valid sync version - derived from the last known sync version and its validity based on the
125- # current state of the source data
125+ # current state of the source data.
126126 # c) whether a full refresh is needed - this is a derivative of the validity of the last known sync version
127- # because if the last known sync version is no longer valid, then our target data is in an invalid-state /
127+ # because if the last known sync version is no longer valid, then our target data is in-an- invalid-state /
128128 # out-of-sync and a full refresh must be forced to sync the data.
129129 #
130130 # the following help us determining the above:
131131 # a) sync_version: the current version of change tracking at source database.
132132 # it's value IS sourced from CHANGE_TRACKING_CURRENT_VERSION()
133133 # and it's value also becomes the last_known_sync_version for the next iteration.
134134 # b) last_known_sync_version: the tracking number of the last time we ran rdl, if we did.
135- # it's value WAS sourced from CHANGE_TRACKING_CURRENT_VERSION()
135+ # it's value WAS sourced from CHANGE_TRACKING_CURRENT_VERSION().
136136 # c) min_valid_version: the minimum version that is valid for use in obtaining change tracking information from
137137 # the specified table.
138- # it's value IS sourced from CHANGE_TRACKING_MIN_VALID_VERSION(OBJECT_ID(..))
138+ # it's value IS sourced from CHANGE_TRACKING_MIN_VALID_VERSION(OBJECT_ID(..)).
139139
140140 get_change_tracking_info_sql = f"" \
141141 f"DECLARE @sync_version BIGINT = CHANGE_TRACKING_CURRENT_VERSION(); \n " \
0 commit comments