src/dirbs/importer/base_delta_importer.py
def _check_for_conflicts_single_partition(self, partition_name):
        """Function to check for conflicts in a single partition."""
        with utils.create_db_connection(self._db_config) as conn, conn.cursor() as cursor:
            cursor.execute(sql.SQL("""SELECT {pk_ids}, COUNT(DISTINCT ({extra_fields}))-1 AS dc
                                        FROM {staging_tbl_partition}
                                    GROUP BY {pk_ids}
                                             HAVING COUNT(DISTINCT ({extra_fields})) > 1""")  # noqa Q441
                           .format(extra_fields=self._extra_field_columns,
                                   staging_tbl_partition=sql.Identifier(partition_name),
                                   pk_ids=self._pk_field_columns))
            return cursor.fetchall()
Function to check for conflicts in a single partition.
Function to check for conflicts in a single partition.
Function to check for conflicts in a single partition .
def _check_for_conflicts_single_partition(self, partition_name):
        with utils.create_db_connection(self._db_config) as conn, conn.cursor() as cursor:
            cursor.execute(sql.SQL("""SELECT {pk_ids}, COUNT(DISTINCT ({extra_fields}))-1 AS dc
                                        FROM {staging_tbl_partition}
                                    GROUP BY {pk_ids}
                                             HAVING COUNT(DISTINCT ({extra_fields})) > 1""")  
                           .format(extra_fields=self._extra_field_columns,
                                   staging_tbl_partition=sql.Identifier(partition_name),
                                   pk_ids=self._pk_field_columns))
            return cursor.fetchall()
def _check_for_conflicts_single_partition ( self , partition_name ) : with utils . create_db_connection ( self . _db_config ) as conn , conn . cursor ( ) as cursor : cursor . execute ( sql . SQL ( """SELECT {pk_ids}, COUNT(DISTINCT ({extra_fields}))-1 AS dc
                                        FROM {staging_tbl_partition}
                                    GROUP BY {pk_ids}
                                             HAVING COUNT(DISTINCT ({extra_fields})) > 1""" ) . format ( extra_fields = self . _extra_field_columns , staging_tbl_partition = sql . Identifier ( partition_name ) , pk_ids = self . _pk_field_columns ) ) return cursor . fetchall ( )
Function to check for conflicts in a single partition.
Function to check for conflicts in a single partition .
"""Function to check for conflicts in a single partition.""" # noqa Q441
self
partition_name