src/dirbs/importer/base_delta_importer.py
def _update_historic_single_shard(self, src_shard_name, dest_shard_name, job_start_time):
        """Update entries in historic table (if import supports IMEI sharding, is called once per shard)."""
        self._remove_from_historic_single_shard(src_shard_name, dest_shard_name, job_start_time, change_type='update')
        return self._add_into_historic_single_shard(src_shard_name, dest_shard_name, job_start_time,
                                                    change_type='update')
Update entries in historic table (if import supports IMEI sharding, is called once per shard).
Update entries in historic table (if import supports IMEI sharding, is called once per shard).
Update entries in historic table ( if import supports IMEI sharding is called once per shard ) .
def _update_historic_single_shard(self, src_shard_name, dest_shard_name, job_start_time):
        self._remove_from_historic_single_shard(src_shard_name, dest_shard_name, job_start_time, change_type='update')
        return self._add_into_historic_single_shard(src_shard_name, dest_shard_name, job_start_time,
                                                    change_type='update')
def _update_historic_single_shard ( self , src_shard_name , dest_shard_name , job_start_time ) : self . _remove_from_historic_single_shard ( src_shard_name , dest_shard_name , job_start_time , change_type = 'update' ) return self . _add_into_historic_single_shard ( src_shard_name , dest_shard_name , job_start_time , change_type = 'update' )
Update entries in historic table (if import supports IMEI sharding, is called once per shard).
Update entries in historic table ( if import supports IMEI sharding is called once per shard ) .
"""Update entries in historic table (if import supports IMEI sharding, is called once per shard)."""
self
src_shard_name
dest_shard_name
job_start_time