src/dirbs/listgen/generator.py
def _process_delta_table_job_result(self, description, future):
        """Function to process the results of a job to store data in delta table table."""
        per_type_counts, duration = future.result()
        per_type_counts_string = ', '.join(['{0} {1} changes'.format(v, k) for k, v in per_type_counts.items()])
        msg = 'Stored delta in table containing {0} (duration {1:.3f}s) [{2}]' \
            .format(description, duration / 1000, per_type_counts_string)
        self._logger.info(msg)
Function to process the results of a job to store data in delta table table.
Function to process the results of a job to store data in delta table table.
Function to process the results of a job to store data in delta table table .
def _process_delta_table_job_result(self, description, future):
        per_type_counts, duration = future.result()
        per_type_counts_string = ', '.join(['{0} {1} changes'.format(v, k) for k, v in per_type_counts.items()])
        msg = 'Stored delta in table containing {0} (duration {1:.3f}s) [{2}]' \
            .format(description, duration / 1000, per_type_counts_string)
        self._logger.info(msg)
def _process_delta_table_job_result ( self , description , future ) : per_type_counts , duration = future . result ( ) per_type_counts_string = ', ' . join ( [ '{0} {1} changes' . format ( v , k ) for k , v in per_type_counts . items ( ) ] ) msg = 'Stored delta in table containing {0} (duration {1:.3f}s) [{2}]' . format ( description , duration / 1000 , per_type_counts_string ) self . _logger . info ( msg )
Function to process the results of a job to store data in delta table table.
Function to process the results of a job to store data in delta table table .
"""Function to process the results of a job to store data in delta table table."""
self
description
future