src/dirbs/importer/abstract_importer.py
def _acquire_import_lock(self):
        """Acquires a PostgreSQL advisory lock to stop multiple imports of the same type happening simultaneously."""
        with self._conn.cursor() as cursor:
            cursor.execute('SELECT pg_try_advisory_lock(%s::BIGINT)', [self._import_lock_key])
            return cursor.fetchone()[0]
Acquires a PostgreSQL advisory lock to stop multiple imports of the same type happening simultaneously.
Acquires a PostgreSQL advisory lock to stop multiple imports of the same type happening simultaneously.
Acquires a PostgreSQL advisory lock to stop multiple imports of the same type happening simultaneously .
def _acquire_import_lock(self):
        with self._conn.cursor() as cursor:
            cursor.execute('SELECT pg_try_advisory_lock(%s::BIGINT)', [self._import_lock_key])
            return cursor.fetchone()[0]
def _acquire_import_lock ( self ) : with self . _conn . cursor ( ) as cursor : cursor . execute ( 'SELECT pg_try_advisory_lock(%s::BIGINT)' , [ self . _import_lock_key ] ) return cursor . fetchone ( ) [ 0 ]
Acquires a PostgreSQL advisory lock to stop multiple imports of the same type happening simultaneously.
Acquires a PostgreSQL advisory lock to stop multiple imports of the same type happening simultaneously .
"""Acquires a PostgreSQL advisory lock to stop multiple imports of the same type happening simultaneously."""
self