Skip to content

Commit

Permalink
[pre-commit.ci] auto fixes from pre-commit.com hooks
Browse files Browse the repository at this point in the history
for more information, see https://pre-commit.ci
  • Loading branch information
pre-commit-ci[bot] committed Mar 6, 2025
1 parent 002c7fe commit a29bf3e
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 8 deletions.
7 changes: 3 additions & 4 deletions diracx-logic/src/diracx/logic/jobs/status.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,14 +29,13 @@
VectorSearchSpec,
)
from diracx.db.os.job_parameters import JobParametersDB
from diracx.db.sql.job.db import JobDB
from diracx.db.sql.job.db import JobDB, _get_columns
from diracx.db.sql.job.schema import Jobs
from diracx.db.sql.job_logging.db import JobLoggingDB
from diracx.db.sql.sandbox_metadata.db import SandboxMetadataDB
from diracx.db.sql.task_queue.db import TaskQueueDB
from diracx.logic.jobs.utils import check_and_prepare_job
from diracx.logic.task_queues.priority import recalculate_tq_shares_for_entity
from diracx.db.sql.job.db import _get_columns
from diracx.db.sql.job.schema import Jobs

logger = logging.getLogger(__name__)

Expand Down Expand Up @@ -514,4 +513,4 @@ async def set_job_parameters_or_attributes(
await job_parameters_db.upsert(
int(job_id),
p_updates_,
)
)
8 changes: 4 additions & 4 deletions diracx-routers/src/diracx/routers/jobs/status.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,8 +12,10 @@
)
from diracx.logic.jobs.status import remove_jobs as remove_jobs_bl
from diracx.logic.jobs.status import reschedule_jobs as reschedule_jobs_bl
from diracx.logic.jobs.status import (
set_job_parameters_or_attributes as set_job_parameters_or_attributes_bl,
)
from diracx.logic.jobs.status import set_job_statuses as set_job_statuses_bl
from diracx.logic.jobs.status import set_job_parameters_or_attributes as set_job_parameters_or_attributes_bl

from ..dependencies import (
Config,
Expand Down Expand Up @@ -136,6 +138,4 @@ async def patch_metadata(
check_permissions: CheckWMSPolicyCallable,
):
await check_permissions(action=ActionType.MANAGE, job_db=job_db, job_ids=updates)
await set_job_parameters_or_attributes_bl(
updates, job_db, job_parameters_db
)
await set_job_parameters_or_attributes_bl(updates, job_db, job_parameters_db)

0 comments on commit a29bf3e

Please sign in to comment.