fix: spelling

Author: martynia

diracx-cli/src/diracx/cli/internal/legacy.py

@@ -96,7 +96,7 @@ def _apply_fixes(raw):
     raw["DIRAC"].pop("Framework", None)
     raw["DIRAC"].pop("Security", None)
 
-    # This is VOMS specific and no longer reqired
+    # This is VOMS specific and no longer required
     raw["DIRAC"].pop("ConnConf", None)
 
     # Setups are no longer supported

diracx-client/src/diracx/_client_importer.py

@@ -241,12 +241,12 @@ def __init__(
     def exec_module(self, module):
         """Import an autorest generated module with two layers of patches."""
         # Import the real module and set its __name__ to the alias. This will
-        # then corrospond to the __init__.py file + the _patch.py file from
+        # then correspond to the __init__.py file + the _patch.py file from
         # plain DiracX. When calling self.original_loader.exec_module it will:
         # 1. Import the real module (e.g. aio/__init__.py)
         # 2. Import any submodules (e.g. _operations)
         # 3. Import the patch module from plain DiracX (e.g. _patch.py,
-        #    overriden by the DiracXPathFinder)
+        #    overridden by the DiracXPathFinder)
         # 4. Replace the submodules module's objects with anything in ._patch.__all__
         super().exec_module(module)
 

diracx-client/src/diracx/client/patches/client/common.py

@@ -132,7 +132,7 @@ def refresh_token(
 
     if response.status_code != 200:
         raise RuntimeError(
-            f"An issue occured while refreshing your access token: {response.json()['detail']}"
+            f"An issue occurred while refreshing your access token: {response.json()['detail']}"
         )
 
     res = response.json()

diracx-client/src/diracx/client/patches/utils.py

@@ -135,7 +135,7 @@ def refresh_token(
 
     if response.status_code != 200:
         raise RuntimeError(
-            f"An issue occured while refreshing your access token: {response.json()['detail']}"
+            f"An issue occurred while refreshing your access token: {response.json()['detail']}"
         )
 
     res = response.json()

diracx-core/src/diracx/core/utils.py

@@ -188,7 +188,7 @@ def get(self, key: str, populate_func: Callable[[], T], blocking: bool = True) -
                 self.locks[key].release()
             if blocking:
                 # It is critical that ``future`` is waited for outside of the lock
-                # as _work aquires the lock before filling the caches. This also
+                # as _work acquires the lock before filling the caches. This also
                 # means we can guarantee that the future has not yet been removed
                 # from the futures dict.
                 wait([future])

diracx-db/src/diracx/db/sql/job/db.py

@@ -50,7 +50,7 @@ class JobDB(BaseSQLDB):
     }
 
     # TODO: this is copied from the DIRAC JobDB
-    # but is overwriten in LHCbDIRAC, so we need
+    # but is overwritten in LHCbDIRAC, so we need
     # to find a way to make it dynamic
     jdl_2_db_parameters = ["JobName", "JobType", "JobGroup"]
 

diracx-db/src/diracx/db/sql/job_logging/schema.py

@@ -44,7 +44,7 @@ def process_result_value(self, value, dialect):
         """
         if value is None:
             return None
-        # Carefully convert from Decimal to datetime to avoid loosing precision
+        # Carefully convert from Decimal to datetime to avoid losing precision
         value += self.MAGIC_EPOC_NUMBER
         value_int = int(value)
         result = datetime.fromtimestamp(value_int, tz=UTC)

diracx-db/src/diracx/db/sql/sandbox_metadata/db.py

@@ -128,7 +128,7 @@ async def assign_sandbox_to_jobs(
         sb_type: SandboxType,
         se_name: str,
     ) -> None:
-        """Mapp sandbox and jobs."""
+        """Map sandbox and jobs."""
         for job_id in jobs_ids:
             # Define the entity id as 'Entity:entity_id' due to the DB definition:
             entity_id = self.jobid_to_entity_id(job_id)

diracx-db/src/diracx/db/sql/task_queue/db.py

@@ -56,7 +56,7 @@ async def get_task_queue_owners_by_group(self, group: str) -> dict[str, int]:
         )
         rows = await self.conn.execute(stmt)
         # Get owners in this group and the amount of times they appear
-        # TODO: I guess the rows are already a list of tupes
+        # TODO: I guess the rows are already a list of tuples
         # maybe refactor
         return {r[0]: r[1] for r in rows if r}
 
@@ -108,7 +108,7 @@ async def set_priorities_for_entity(
         tq_ids: list[int],
         priority: float,
     ):
-        """Set the priority for a user/userGroup combo given a splitted share."""
+        """Set the priority for a user/userGroup combo given a split share."""
         update_stmt = (
             update(TaskQueues)
             .where(TaskQueues.TQId.in_(tq_ids))

diracx-db/src/diracx/db/sql/utils/base.py

@@ -51,7 +51,7 @@ class BaseSQLDB(metaclass=ABCMeta):
     of the same database. To list the available implementations use
     `BaseSQLDB.available_implementations(db_name)`. The first entry in this list
     will be the preferred implementation and it can be initialized by calling
-    it's `__init__` function with a URL perviously obtained from
+    it's `__init__` function with a URL previously obtained from
     `BaseSQLDB.available_urls`.
 
     To control the lifetime of the SQLAlchemy engine used for connecting to the