src/dirbs/importer/base_delta_importer.py
def _all_fields_no_dupes_columns(self):
        """Return column names defining all the primary key and extra_fields aggregated with 'first' aggregate."""
        if self._extra_field_identifiers:
            # '"imei_norm", "first"("reporting_date")'
            aggregate_field_names = [sql.SQL('first({ex})').format(ex=ex) for ex in self._extra_field_identifiers]
            return sql.SQL(', ').join(self._pk_field_identifiers + aggregate_field_names)
        return self._pk_field_columns
Return column names defining all the primary key and extra_fields aggregated with 'first' aggregate.
Return column names defining all the primary key and extra_fields aggregated with 'first' aggregate.
Return column names defining all the primary key and extra_fields aggregated with ' first ' aggregate .
def _all_fields_no_dupes_columns(self):
        if self._extra_field_identifiers:
            aggregate_field_names = [sql.SQL('first({ex})').format(ex=ex) for ex in self._extra_field_identifiers]
            return sql.SQL(', ').join(self._pk_field_identifiers + aggregate_field_names)
        return self._pk_field_columns
def _all_fields_no_dupes_columns ( self ) : if self . _extra_field_identifiers : aggregate_field_names = [ sql . SQL ( 'first({ex})' ) . format ( ex = ex ) for ex in self . _extra_field_identifiers ] return sql . SQL ( ', ' ) . join ( self . _pk_field_identifiers + aggregate_field_names ) return self . _pk_field_columns
Return column names defining all the primary key and extra_fields aggregated with 'first' aggregate.
Return column names defining all the primary key and extra_fields aggregated with ' first ' aggregate .
"""Return column names defining all the primary key and extra_fields aggregated with 'first' aggregate.""" # '"imei_norm", "first"("reporting_date")'
self