src/dirbs/importer/abstract_importer.py
def _init_staging_table_shards(self):
        """Method to create IMEI shards in the staging table if supported by the importer."""
        assert self._supports_imei_shards
        with db_role_setter(self._conn, role_name=self._owner_role_name):
            tbl_name = self._staging_tbl_name
            partition_utils.create_imei_shard_partitions(self._conn, tbl_name=tbl_name, unlogged=True)
            for name, rstart, rend in partition_utils.physical_imei_shards(self._conn, tbl_name=tbl_name):
                self._on_staging_table_shard_creation(name, rstart, rend)
Method to create IMEI shards in the staging table if supported by the importer.
Method to create IMEI shards in the staging table if supported by the importer.
Method to create IMEI shards in the staging table if supported by the importer .
def _init_staging_table_shards(self):
        assert self._supports_imei_shards
        with db_role_setter(self._conn, role_name=self._owner_role_name):
            tbl_name = self._staging_tbl_name
            partition_utils.create_imei_shard_partitions(self._conn, tbl_name=tbl_name, unlogged=True)
            for name, rstart, rend in partition_utils.physical_imei_shards(self._conn, tbl_name=tbl_name):
                self._on_staging_table_shard_creation(name, rstart, rend)
def _init_staging_table_shards ( self ) : assert self . _supports_imei_shards with db_role_setter ( self . _conn , role_name = self . _owner_role_name ) : tbl_name = self . _staging_tbl_name partition_utils . create_imei_shard_partitions ( self . _conn , tbl_name = tbl_name , unlogged = True ) for name , rstart , rend in partition_utils . physical_imei_shards ( self . _conn , tbl_name = tbl_name ) : self . _on_staging_table_shard_creation ( name , rstart , rend )
Method to create IMEI shards in the staging table if supported by the importer.
Method to create IMEI shards in the staging table if supported by the importer .
"""Method to create IMEI shards in the staging table if supported by the importer."""
self