src/dirbs/importer/operator_data_importer.py
def _process_monthly_network_triplets_result(self, state, month, year, future):
        """Process a monthly_network_triplet future, mutating the passed state."""
        inserted_or_updated_triplet_count = future.result()  # will throw exception if this one was thrown in thread
        state['num_processed'] += 1
        state['num_inserted_or_updated'] += inserted_or_updated_triplet_count
        self._logger.info('Updated monthly_network_triplet tables for {0:02d}/{1:d} [{2:d} of {3:d} partitions]'
                          .format(month, year, state['num_processed'], state['num_jobs']))
Process a monthly_network_triplet future, mutating the passed state.
Process a monthly_network_triplet future, mutating the passed state.
Process a monthly_network_triplet future mutating the passed state .
def _process_monthly_network_triplets_result(self, state, month, year, future):
        inserted_or_updated_triplet_count = future.result()  
        state['num_processed'] += 1
        state['num_inserted_or_updated'] += inserted_or_updated_triplet_count
        self._logger.info('Updated monthly_network_triplet tables for {0:02d}/{1:d} [{2:d} of {3:d} partitions]'
                          .format(month, year, state['num_processed'], state['num_jobs']))
def _process_monthly_network_triplets_result ( self , state , month , year , future ) : inserted_or_updated_triplet_count = future . result ( ) state [ 'num_processed' ] += 1 state [ 'num_inserted_or_updated' ] += inserted_or_updated_triplet_count self . _logger . info ( 'Updated monthly_network_triplet tables for {0:02d}/{1:d} [{2:d} of {3:d} partitions]' . format ( month , year , state [ 'num_processed' ] , state [ 'num_jobs' ] ) )
Process a monthly_network_triplet future, mutating the passed state.
Process a monthly_network_triplet future mutating the passed state .
"""Process a monthly_network_triplet future, mutating the passed state.""" # will throw exception if this one was thrown in thread
self
state
month
year
future