def run_datastore_upgrade(db_access, zookeeper, log_postfix, total_entities):
 ensure_app_is_not_running()
 validate_and_update_entities(db_access, zookeeper, log_postfix, total_entities)
 logging.info('Updated invalid entities and deleted tombstoned entities.')
 db_access.set_metadata(cassandra_interface.VERSION_INFO_KEY, str(cassandra_interface.EXPECTED_DATA_VERSION))
 logging.info('Stored the data version successfully.')
 db_access.delete_table(dbconstants.JOURNAL_TABLE)
 logging.info('Deleted Journal Table sucessfully.')

def run_datastore_upgrade ( db_access , zookeeper , log_postfix , total_entities ) : ensure_app_is_not_running ( ) validate_and_update_entities ( db_access , zookeeper , log_postfix , total_entities ) logging . info ( 'Updated invalid entities and deleted tombstoned entities.' ) db_access . set_metadata ( cassandra_interface . VERSION_INFO_KEY , str ( cassandra_interface . EXPECTED_DATA_VERSION ) ) logging . info ( 'Stored the data version successfully.' ) db_access . delete_table ( dbconstants . JOURNAL_TABLE ) logging . info ( 'Deleted Journal Table sucessfully.' )
runs the data upgrade process of fetching .